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