class EventStream::Registry
Public Class Methods
lookup(stream_name)
click to toggle source
# File lib/event_stream/registry.rb, line 15 def self.lookup(stream_name) streams[stream_name] || (raise UnregisteredStream) end
register(stream_name, stream)
click to toggle source
# File lib/event_stream/registry.rb, line 11 def self.register(stream_name, stream) streams[stream_name] = stream end