initialValueStream method

Stream<T> initialValueStream()

Implementation

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