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