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