Module: EventStream

Extended by:

Forwardable

Defined in:

lib/event_stream.rb,
lib/event_stream/event.rb,
lib/event_stream/stream.rb,
lib/event_stream/version.rb,
lib/event_stream/registry.rb,
lib/event_stream/subscriber.rb,
lib/event_stream/test_helper.rb,
lib/event_stream/subscriber_dsl.rb

Defined Under Namespace

Modules: Assertions, SubscriberDSL, TestEventStream Classes: Event, Registry, Stream, Subscriber

Constant Summary

VERSION =

"1.0.0"

Class Method Summary

• .[](stream_name) ⇒ Stream

  Returns the stream for a stream name from the stream registry.

• .default_stream ⇒ Stream

  The default event stream.

• .register_stream(stream_name, stream) ⇒ Object

  Registers a stream, associating it with a specific stream name.

Class Method Details

.[](stream_name) ⇒ Stream

Returns the stream for a stream name from the stream registry.

Parameters:

• stream_name (Symbol)

Returns:

• (Stream)

# File 'lib/event_stream.rb', line 15

def [](stream_name)
  Registry.lookup(stream_name)
end

.default_stream ⇒ Stream

The default event stream

Returns:

• (Stream)

# File 'lib/event_stream.rb', line 28

def default_stream
  self[:default]
end

.register_stream(stream_name, stream) ⇒ Object

Registers a stream, associating it with a specific stream name

Parameters:

• stream_name (Symbol)
• stream (Stream)

# File 'lib/event_stream.rb', line 22

def register_stream(stream_name, stream)
  Registry.register(stream_name, stream)
end