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