class IOPromise::ExecutorPool::Sequential

Public Instance Methods

execute_continue() click to toggle source
# File lib/iopromise/executor_pool/sequential.rb, line 10
def execute_continue
  @pending.dup.each do |active|
    execute_continue_item(active)
    
    unless active.fulfilled?
      # once we're waiting on our one next item, we're done
      return
    end
  end
    
  # if we fall through to here, we have nothing to wait on.
end
execute_continue_item(item) click to toggle source
# File lib/iopromise/executor_pool/sequential.rb, line 6
def execute_continue_item(item)
  item.execute_continue
end