class RbbtProcessQueue
Public Instance Methods
Source
# File lib/rbbt/util/concurrency/processes/refactor.rb, line 11 def callback(&block) @callback = block end
Source
# File lib/rbbt/util/concurrency/processes/refactor.rb, line 6 def init(&block) @worker_proc = block start_process(&@callback) end
Source
# File lib/rbbt/util/concurrency/processes/refactor.rb, line 15 def process(obj) self.write(obj) end