initialValueStream method

Stream<T> initialValueStream()

Implementation

Async.Stream<T> initialValueStream() => subject.stream
    .asBroadcastStream()
    .mergeWith([Future.value(value).toStream()]);