transformStreams method

Stream<T> transformStreams(
  1. Map<StreamNode, Stream> existingStreams
)

Implementation

Stream<T> transformStreams(Map<StreamNode, Stream> existingStreams) =>
    mapping.bind(existingStreams[input]! as Stream<S>);