ReplayConnectableStream<T> constructor

ReplayConnectableStream<T>(
  1. Stream<T> stream, {
  2. int? maxSize,
  3. bool sync = false,
})

Constructs a Stream which only begins emitting events when the connect method is called, this Stream acts like a ReplaySubject.

Implementation

ReplayConnectableStream(Stream<T> stream, {int? maxSize, bool sync = false})
    : super(
        stream,
        ReplaySubject<T>(maxSize: maxSize, sync: sync),
      );