bindStream method

void bindStream(
  1. Stream<T> stream
)

Implementation

void bindStream(Stream<T> stream) {
  late StreamSubscription subscription;
  subscription = stream.asBroadcastStream().listen(
    (event) => value = event,
    onDone: () {
      subscription.cancel();
      _subscriptions.remove(subscription);
    },
  );
  _subscriptions[stream] = subscription;
}