Class: Aggro::FileStore::Reader

Inherits:
Object
  • Object
show all
Defined in:
lib/aggro/file_store/reader.rb

Overview

Private: Deserialized events from an IO object.

Instance Method Summary collapse

Constructor Details

#initialize(data_io, index_io) ⇒ Reader

Returns a new instance of Reader.



5
6
7
8
 
# File 'lib/aggro/file_store/reader.rb', line 5

def initialize(data_io, index_io)
  @data_io = data_io
  @index_io = index_io
end

Instance Method Details

#read ⇒ Object 



10
11
12
13
14
15
16
 
# File 'lib/aggro/file_store/reader.rb', line 10

def read
  Enumerator.new do |yielder|
    stream.each do |raw_event|
      yielder << EventSerializer.deserialize(raw_event)
    end
  end
end