class Fluent::MessagePackEventStream
Public Class Methods
new(data, cached_unpacker = nil)
click to toggle source
Keep cached_unpacker argument for existence plugins
# File lib/fluent/event.rb, line 136 def initialize(data, cached_unpacker = nil) @data = data end
Public Instance Methods
each(&block)
click to toggle source
# File lib/fluent/event.rb, line 144 def each(&block) # TODO format check unpacker = MessagePack::Unpacker.new unpacker.feed_each(@data, &block) nil end
repeatable?()
click to toggle source
# File lib/fluent/event.rb, line 140 def repeatable? true end
to_msgpack_stream()
click to toggle source
# File lib/fluent/event.rb, line 151 def to_msgpack_stream @data end