PublishConnectableObservable<T> constructor

PublishConnectableObservable<T>(
  1. Stream<T> source
)

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

Implementation

factory PublishConnectableObservable(Stream<T> source) {
  return PublishConnectableObservable<T>._(source, PublishSubject<T>());
}