ValueStreamFutureExtensions<X> extension Null safety

on

Methods

sampled() ValueStream<X?>
thenMap<R>(R mapper(X input)) ValueStream<Future<R>>