class Async::WorkerPool::Worker
def call(work)
def call(work) promise = Promise.new(work) @work.push(promise) begin return promise.wait ensure promise.cancel end end
def call(work) promise = Promise.new(work) @work.push(promise) begin return promise.wait ensure promise.cancel end end