bindStream method

void bindStream(
  1. Stream<T> stream
)

Binds an existing Stream<T> to this Rx

Implementation

void bindStream(Stream<T> stream) {
  // final listSubscriptions =
  //     _subscriptions[subject] ??= <StreamSubscription>[];

  final sub = stream.listen((va) => value = va);
  reportAdd(sub.cancel);
}