addListener method

void addListener(
  1. Stream<int> rxGetx
)
inherited

This is an internal method. Subscribe to changes on the inner stream.

Implementation

void addListener(Stream<T> rxGetx) {
  if (_subscriptions.containsKey(rxGetx)) {
    return;
  }
  _subscriptions[rxGetx] = rxGetx.listen((data) {
    subject.add(data);
  });
}