class Delayer::Deferred::Request::NextWorker

Fiberが次のWorkerを要求している時に返す値。 新たなインスタンスは作らず、 NEXT_WORKER にあるインスタンスを使うこと。

Public Instance Methods

accept_request(worker:, deferred:) click to toggle source

deferred に渡された次のChainableに、 deferred の戻り値を渡す要求を出す。

Args

deferred

実行が完了したDeferred 。次のDeferredとして deferred.child を呼び出す

worker

このDeferredチェインを実行しているWorker

# File lib/delayer/deferred/request.rb, line 19
def accept_request(worker:, deferred:)
  if deferred.has_child?
    worker.push(deferred.child)
  else
    deferred.add_child_observer(worker)
  end
end