clone method

@override StreamingBatchFlow<TIn, TOut> clone()

Creates a deep copy of this AsyncFlow.

Implementation

@override
StreamingBatchFlow<TIn, TOut> clone() {
  final clonedNodes = nodes.map((node) => node.clone()).toList();
  return StreamingBatchFlow<TIn, TOut>(clonedNodes)
    ..name = name
    ..params = Map.from(params);
}