Keep cached_unpacker argument for existence plugins
# File lib/fluent/event.rb, line 138 def initialize(data, cached_unpacker = nil) @data = data end
# File lib/fluent/event.rb, line 146 def each(&block) # TODO format check unpacker = Fluent::Engine.msgpack_factory.unpacker unpacker.feed_each(@data, &block) nil end
# File lib/fluent/event.rb, line 142 def repeatable? true end
# File lib/fluent/event.rb, line 153 def to_msgpack_stream @data end