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