addListener method

  1. @override
void addListener(
  1. Stream<Map<K, V>> rxGetX
)
override

Adds a listener to stream

Implementation

@override
void addListener(Stream<Map<K, V>> rxGetX) {
  if (_subscriptions.containsKey(rxGetX)) {
    return;
  }
  _subscriptions[rxGetX] = rxGetX.listen((data) {
    subject.add(data);
  });
}