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

Keep cached_unpacker argument for existence plugins



138
139
140
 
# File 'lib/fluent/event.rb', line 138

def initialize(data, cached_unpacker = nil)
  @data = data
end

Instance Method Details

#each(&block) ⇒ Object 



146
147
148
149
150
151
 
# File 'lib/fluent/event.rb', line 146

def each(&block)
  # TODO format check
  unpacker = Fluent::Engine.msgpack_factory.unpacker
  unpacker.feed_each(@data, &block)
  nil
end

#repeatable? ⇒ Boolean

Returns:

  • (Boolean) 


142
143
144
 
# File 'lib/fluent/event.rb', line 142

def repeatable?
  true
end

#to_msgpack_stream ⇒ Object 



153
154
155
 
# File 'lib/fluent/event.rb', line 153

def to_msgpack_stream
  @data
end