transformStreams method
MapEntry<StreamController<T> , StreamSubscription<T> >
transformStreams(
- Map<
StreamNode, Stream> existingStreams
Implementation
MapEntry<StreamController<T>, StreamSubscription<T>> transformStreams(
Map<StreamNode, Stream> existingStreams) =>
MapEntry(controller,
(existingStreams[this]! as Stream<T>).listen(controller.add));