Method: Aggro::FileStore::Writer#write

Defined in:
lib/aggro/file_store/writer.rb

#write(events) ⇒ Object 



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

def write(events)
  events.each do |event|
    @data_io.write EventSerializer.serialize(event)
    write_to_index @data_io.pos
  end

  @data_io.flush
  @index_io.flush
end