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