class Fluent::MessagePackEventStream
Public Class Methods
new(data, cached_unpacker=nil)
click to toggle source
# File lib/fluent/event.rb, line 138 def initialize(data, cached_unpacker=nil) @data = data end
Public Instance Methods
each(&block)
click to toggle source
# File lib/fluent/event.rb, line 146 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 142 def repeatable? true end
to_msgpack_stream()
click to toggle source
# File lib/fluent/event.rb, line 153 def to_msgpack_stream @data end