module EventStream::SubscriberDSL::ClassMethods
Public Instance Methods
event_stream(event_stream)
click to toggle source
# File lib/event_stream/subscriber_dsl.rb, line 36 def event_stream(event_stream) self._event_stream = event_stream end
on(filter, &action)
click to toggle source
# File lib/event_stream/subscriber_dsl.rb, line 40 def on(filter, &action) self._event_subscribers << Subscriber.create(filter, &action) end
subscribe()
click to toggle source
# File lib/event_stream/subscriber_dsl.rb, line 44 def subscribe _event_subscribers.each { |subscriber| _event_stream.add_subscriber(subscriber) } end