Class/Module Index [+]

Quicksearch

Fluent::MessagePackEventStream

Public Class Methods

new(data, cached_unpacker=nil) click to toggle source
# File lib/fluent/event.rb, line 116
def initialize(data, cached_unpacker=nil)
  @data = data
end

Public Instance Methods

each(&block) click to toggle source
# File lib/fluent/event.rb, line 124
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 120
def repeatable?
  true
end
to_msgpack_stream() click to toggle source
# File lib/fluent/event.rb, line 131
def to_msgpack_stream
  @data
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.