publishValueConnecting<T, S> method

ValueStream<S?> publishValueConnecting<T, S>(
  1. ValueStream<T> observable,
  2. FutureOr<S?> f(
    1. T? value
    )
)

Implementation

ValueStream<S?> publishValueConnecting<T, S>(
  ValueStream<T> observable,
  FutureOr<S?> Function(T? value) f,
) {
  final v = f(observable.valueOrNull);
  final valueObservable = observable
      .asyncMap(f)
      .distinct()
      .publishValueSeeded(v is Future ? null : v as S);
  _subscriptions.add(valueObservable.connect());

  return valueObservable;
}