ReplayConnectableObservable<T> constructor

ReplayConnectableObservable<T>(Stream<T> stream, { int maxSize })

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

Implementation

factory ReplayConnectableObservable(Stream<T> stream, {int maxSize}) {
  return ReplayConnectableObservable<T>._(
    stream,
    ReplaySubject<T>(maxSize: maxSize),
  );
}