Fluent::EventStream
Keep cached_unpacker argument for existence plugins
# File lib/fluent/event.rb, line 136 def initialize(data, cached_unpacker = nil) @data = data end
# File lib/fluent/event.rb, line 144 def each(&block) # TODO format check unpacker = MessagePack::Unpacker.new unpacker.feed_each(@data, &block) nil end
# File lib/fluent/event.rb, line 140 def repeatable? true end
# File lib/fluent/event.rb, line 151 def to_msgpack_stream @data end
[Validate]
Generated with the Darkfish Rdoc Generator 2.