class Eventr::Consumer

Attributes

block[R]
publisher[R]

Public Class Methods

new(publisher, &block) click to toggle source
# File lib/eventr/actors.rb, line 152
def initialize(publisher, &block)
  @publisher = publisher
  @block     = block
end

Public Instance Methods

main() click to toggle source
# File lib/eventr/actors.rb, line 157
def main
  loop { block.call(publisher.pop) }
end