bindStream method

void bindStream(
  1. Stream<T> stream
)

Binds an existing Stream<T> to this Rx

Implementation

void bindStream(Stream<T> stream) {
  final sub = stream.listen((va) => value = va);
  reportAdd(sub.cancel);
}