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