transformStreams method

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

Implementation

Stream<T> transformStreams(Map<StreamNode, Stream> existingStreams) =>
    schedule.stream(existingStreams[input]! as Stream<T>);