class Gallus::Output::Stream

Public Class Methods

new(stream, format) click to toggle source
# File lib/gallus/output/stream.rb, line 4
def initialize(stream, format)
  @mutex = Mutex.new
  @stream, @format = stream, format
end

Public Instance Methods

call(event) click to toggle source
# File lib/gallus/output/stream.rb, line 9
def call(event)
  @mutex.synchronize { call!(event) }
end
call!(event) click to toggle source
# File lib/gallus/output/stream.rb, line 13
def call!(event)
  @stream.write(@format.call(event) + "\n")
end