transformStreams method

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

Implementation

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