Fluent::EventStream
# File lib/fluent/event.rb, line 116 def initialize(data, cached_unpacker=nil) @data = data end
# File lib/fluent/event.rb, line 124 def each(&block) # TODO format check unpacker = MessagePack::Unpacker.new unpacker.feed_each(@data, &block) nil end
# File lib/fluent/event.rb, line 120 def repeatable? true end
# File lib/fluent/event.rb, line 131 def to_msgpack_stream @data end
[Validate]
Generated with the Darkfish Rdoc Generator 2.