attach method
MapEntry<StreamController<T> , StreamSubscription<T> >
attach(
- Map<
StreamNode, Stream> existingStreams
Implementation
MapEntry<StreamController<T>, StreamSubscription<T>> attach(
Map<StreamNode, Stream> existingStreams) {
final searchedName = name?.replaceFirst(RegExp(r"copy-"), "");
final copiedNodeAndStream = existingStreams.entries
.firstWhere((element) => element.key.name == searchedName);
final copiedStream = copiedNodeAndStream.value as Stream<T>;
return MapEntry(
controller, copiedStream.listen((event) => controller.add(event)));
}