Class: RbbtProcessQueue

Inherits:
WorkQueue
  • Object
show all
Defined in:
lib/rbbt/util/concurrency/processes/socket.rb,
lib/rbbt/util/concurrency/processes/worker.rb,
lib/rbbt/util/concurrency/processes/refactor.rb

Defined Under Namespace

Classes: RbbtProcessQueueWorker, RbbtProcessSocket

Instance Method Summary collapse

Instance Method Details

#callback(&block) ⇒ Object 



11
12
13
 
# File 'lib/rbbt/util/concurrency/processes/refactor.rb', line 11

def callback(&block)
  @callback = block
end

#init(&block) ⇒ Object 



6
7
8
9
 
# File 'lib/rbbt/util/concurrency/processes/refactor.rb', line 6

def init(&block)
  @worker_proc = block
  start_process(&@callback)
end

#process(obj) ⇒ Object 



15
16
17
 
# File 'lib/rbbt/util/concurrency/processes/refactor.rb', line 15

def process(obj)
  self.write(obj)
end