select<R, P> method

Stream<R> select<R, P>(
  1. Selector<S, R> selector, [
  2. dynamic props
])

Stream the state of the of the store given a Selector.

Implementation

Stream<R> select<R, P>(Selector<S, R> selector, [dynamic props]) {
  Stream<R> newStream =
      state.map((state) => selector(state, props)).distinct();
  BehaviorSubject<R> subject = BehaviorSubject();
  subject.add(selector(state.value, props));
  subject.addStream(newStream);
  return subject;
}