publishValueConnecting<T, S> method
ValueStream<S?>
publishValueConnecting<T, S>(
- ValueStream<
T> observable, - FutureOr<
S?> f(- 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;
}