bindStream method

void bindStream(
  1. Stream<T> stream
)

Implementation

void bindStream(Stream<T> stream) {
  _checkDisposed();
  unawaited(_subscriptions?.remove(stream)?.cancel());
  (_subscriptions ??= {})[stream] =
      (stream.isBroadcast ? stream : stream.asBroadcastStream()).listen(
    (event) => value = event,
    onError: (e, s) => debugPrint('RxMixin error: $e'),
    onDone: () => _subscriptions?.remove(stream),
  );
}