initialValueStream method

Stream<T> initialValueStream()

Implementation

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