Class: FlowNodes::AsyncFlow

Inherits:
Flow show all
Defined in:
lib/flow_nodes/async_flow.rb

Overview

A flow that can orchestrate both synchronous and asynchronous nodes.

Direct Known Subclasses

AsyncBatchFlow, AsyncParallelBatchFlow

Instance Attribute Summary

Attributes inherited from Flow

#start_node

Attributes inherited from BaseNode

#params, #successors

Instance Method Summary collapse

Methods inherited from Flow

#initialize, #start

Methods inherited from BaseNode

#-, #>>, #exec, #initialize, #initialize_copy, #nxt, #set_params

Constructor Details

This class inherits a constructor from FlowNodes::Flow

Instance Method Details

#_run(_s) ⇒ Object 



12
13
14
 
# File 'lib/flow_nodes/async_flow.rb', line 12

def _run(_s)
  raise "Use run_async for AsyncFlow."
end

#run(s) ⇒ Object 



6
 
# File 'lib/flow_nodes/async_flow.rb', line 6

def run(s) = run_async(s)

#run_async(s) ⇒ Object 



8
9
10
 
# File 'lib/flow_nodes/async_flow.rb', line 8

def run_async(s)
  _run_async(s)
end