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