class Logux::Stream

Attributes

stream[R]

Public Class Methods

new(stream) click to toggle source
# File lib/logux/stream.rb, line 11
def initialize(stream)
  @stream = stream
end

Public Instance Methods

write(payload) click to toggle source
# File lib/logux/stream.rb, line 15
def write(payload)
  processed_payload = process(payload)
  Logux.logger.debug("Write to Logux response: #{processed_payload}")
  stream << processed_payload
end

Private Instance Methods

process(payload) click to toggle source
# File lib/logux/stream.rb, line 23
def process(payload)
  payload.is_a?(::String) ? payload : payload.to_json
end