multicastReplay method

Observable<T> multicastReplay(
  1. int bufferSize
)

Multicast replay observable make multiple observers share single source subscription.

Replayer is used to forward source item to downward observers.

Shared subscription keep alive using ARC (auto reference count) of observers.

Latest n items will be replayed to newly added observer.

Implementation

Observable<T> multicastReplay(int bufferSize) {
  return multicast(
    createSubject: () => Replayer<T>(
      bufferSize: bufferSize
    ),
  );
}