module Concurrent

def dataflow(*inputs, &block)

Raises:
  • (ArgumentError) - if any of the inputs are not `IVar`s
  • (ArgumentError) - if no block is given

Returns:
  • (Object) - the result of all the operations

Other tags:
    Yieldreturn: - the result of the block operation

Other tags:
    Yieldparam: inputs - each of the `Future` inputs to the dataflow

Other tags:
    Yield: - The operation to perform once all the dependencies are met

Parameters:
  • inputs (Future) -- zero or more `Future` operations that this dataflow depends upon 
def dataflow(*inputs, &block)
  dataflow_with(Concurrent.global_io_executor, *inputs, &block)
end