addListener method

void addListener(
  1. Stream<Set<E>> rxGetX
)
override

Adds a listener to stream

Implementation

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