Method: Akasha::Storage::MemoryEventStore::Stream#initialize

Defined in:
lib/akasha/storage/memory_event_store/stream.rb

#initialize(&before_write) ⇒ Stream

Creates a new event stream. Accepts an optional block, allowing for filtering new events and triggering side-effects, before new events are appended to the stream,



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

def initialize(&before_write)
  @before_write = before_write || identity
  @events = []
  @metadata = {}
  @monitor = Monitor.new
end