Class: IOPromise::Faraday::FaradayExecutorPool

Inherits:
ExecutorPool::Base show all
Defined in:
lib/iopromise/faraday/executor_pool.rb

Instance Method Summary collapse

Methods inherited from ExecutorPool::Base

#begin_executing, #complete, for, #initialize, #register, #sync

Constructor Details

This class inherits a constructor from IOPromise::ExecutorPool::Base

Instance Method Details

#execute_continue(ready_readers, ready_writers, ready_exceptions) ⇒ Object 



8
9
10
11
12
13
14
15
16
 
# File 'lib/iopromise/faraday/executor_pool.rb', line 8

def execute_continue(ready_readers, ready_writers, ready_exceptions)
  # mark all pending promises as executing since they could be started any time now.
  # ideally we would do this on dequeue.
  @pending.each do |promise|
    begin_executing(promise) unless promise.started_executing?
  end

  ContinuableHydra.for_current_thread.execute_continue(ready_readers, ready_writers, ready_exceptions)
end