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>[];
  listSubscriptions.add(stream.listen((va) => value = va));
}