class Fluent::EventStream

Public Instance Methods

each(&block) click to toggle source
# File lib/fluent/event.rb, line 26
def each(&block)
  raise NotImplementedError, "DO NOT USE THIS CLASS directly."
end
repeatable?() click to toggle source
# File lib/fluent/event.rb, line 22
def repeatable?
  false
end
to_msgpack_stream() click to toggle source
# File lib/fluent/event.rb, line 30
def to_msgpack_stream
  out = $use_msgpack_5 ? MessagePack::Buffer.new : ''.force_encoding('ASCII-8BIT')
  each {|time,record|
    [time,record].to_msgpack(out)
  }
  out.to_s
end