transformStreams method

MapEntry<StreamController<T>, StreamSubscription<T>> transformStreams(
  1. 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));