Class: Fluent::MessagePackEventStream

Inherits:
EventStream show all
Defined in:
lib/fluent/event.rb

Instance Method Summary collapse

Constructor Details

#initialize(data, cached_unpacker = nil) ⇒ MessagePackEventStream

Returns a new instance of MessagePackEventStream.



115
116
117
118
 
# File 'lib/fluent/event.rb', line 115

def initialize(data, cached_unpacker=nil)
  @data = data
  @unpacker = cached_unpacker || MessagePack::Unpacker.new
end

Instance Method Details

#each(&block) ⇒ Object 



124
125
126
127
128
129
 
# File 'lib/fluent/event.rb', line 124

def each(&block)
  @unpacker.reset
  # TODO format check
  @unpacker.feed_each(@data, &block)
  nil
end

#repeatable? ⇒ Boolean

Returns:

  • (Boolean) 


120
121
122
 
# File 'lib/fluent/event.rb', line 120

def repeatable?
  true
end

#to_msgpack_stream ⇒ Object 



131
132
133
 
# File 'lib/fluent/event.rb', line 131

def to_msgpack_stream
  @data
end