module EventStream

Constants

VERSION

Public Class Methods

[](stream_name) click to toggle source

Returns the stream for a stream name from the stream registry. @param stream_name [Symbol] @return [Stream]

# File lib/event_stream.rb, line 15
def [](stream_name)
  Registry.lookup(stream_name)
end
default_stream() click to toggle source

The default event stream @return [Stream]

# File lib/event_stream.rb, line 28
def default_stream
  self[:default]
end
register_stream(stream_name, stream) click to toggle source

Registers a stream, associating it with a specific stream name @param stream_name [Symbol] @param stream [Stream]

# File lib/event_stream.rb, line 22
def register_stream(stream_name, stream)
  Registry.register(stream_name, stream)
end