attach method

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