Class: Akasha::Storage::MemoryEventStore::Stream

Inherits:
Object
  • Object
show all
Defined in:
lib/akasha/storage/memory_event_store/stream.rb

Overview

Memory-based event stream.

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Stream

Returns a new instance of Stream.



6
7
8
 
# File 'lib/akasha/storage/memory_event_store/stream.rb', line 6

def initialize
  @events = []
end

Instance Method Details

#read_events(start, page_size, &block) ⇒ Object

Reads events from the stream starting from ‘start` inclusive. If block given, reads all events from the start in pages of `page_size`. If block not given, reads `page_size` events from the start.



18
19
20
21
22
23
24
 
# File 'lib/akasha/storage/memory_event_store/stream.rb', line 18

def read_events(start, page_size, &block)
  if block_given?
    @events.lazy.drop(start).each_slice(page_size, &block)
  else
    @events[start..start + page_size]
  end
end

#write_events(events) ⇒ Object

Appends events to the stream.



11
12
13
 
# File 'lib/akasha/storage/memory_event_store/stream.rb', line 11

def write_events(events)
  @events += events
end