Class: Eventr::Publisher

Inherits:

SupervisedObject

• Object
• SupervisedObject
• Eventr::Publisher

Defined in:

lib/eventr/actors.rb

Instance Method Summary

• #initialize(&block) ⇒ Publisher constructor

  A new instance of Publisher.

• #main ⇒ Object
• #pop(non_block = false) ⇒ Object (also: #shift)

Methods inherited from SupervisedObject

#application, #on_exception, #on_exception=, #sleep_time_from_backoff, #start, #start_application_thread, #start_supervisor_thread, #stop, #supervisor, #threads

Constructor Details

#initialize(&block) ⇒ Publisher

Returns a new instance of Publisher.

# File 'lib/eventr/actors.rb', line 116

def initialize(&block)
  @block   = block
  @events  = Queue.new
end

Instance Method Details

#main ⇒ Object

# File 'lib/eventr/actors.rb', line 126

def main
  block.call(events)
end

#pop(non_block = false) ⇒ Object Also known as: shift

# File 'lib/eventr/actors.rb', line 121

def pop(non_block=false)
  events.pop(non_block)
end