StreamingBatchFlow<TIn, TOut> constructor

StreamingBatchFlow<TIn, TOut>(
  1. List<BaseNode> nodes
)

Creates an instance of StreamingBatchFlow.

The nodes parameter is a list of BaseNode instances that make up the flow. The nodes are chained together in the order they are provided.

Implementation

StreamingBatchFlow(this.nodes) {
  if (nodes.isEmpty) {
    throw StateError('The list of nodes cannot be empty.');
  }

  start(nodes.first);
  for (var i = 0; i < nodes.length - 1; i++) {
    nodes[i].next(nodes[i + 1]);
  }
}