transformStreams method
Implementation
Stream<Lifecycle<T>> transformStreams(
Map<StreamNode, Stream> existingStreams) =>
schedule.lifecycleStream(
streams: existingStreams,
startStream: existingStreams[input]! as Stream<Lifecycle<T>>);