stream property
Stream<T>
get
stream
Implementation
Stream<T> get stream {
final controller = StreamController<T>();
final subscriptions = <StreamSubscription<T>>[];
for (final stream in streams) {
late StreamSubscription<T> subscription;
subscription = stream.listen(
controller.add,
onError: controller.addError,
onDone: () {
subscriptions.remove(subscription);
if (subscriptions.isEmpty) {
controller.close();
}
},
);
subscriptions.add(subscription);
}
return controller.stream;
}