Hi there! Are you looking for the official Deno documentation? Try docs.deno.com for all your Deno learning needs.

publishReplay

deprecated

Creates a ConnectableObservable that uses a ReplaySubject internally.

@deprecated

Will be removed in v8. To create a connectable observable that uses a ReplaySubject under the hood, use connectable. source.pipe(publishReplay(size, time, scheduler)) is equivalent to connectable(source, { connector: () => new ReplaySubject(size, time, scheduler), resetOnDisconnect: false }). If you're using refCount after publishReplay, use the share operator instead. publishReplay(size, time, scheduler), refCount() is equivalent to share({ connector: () => new ReplaySubject(size, time, scheduler), resetOnError: false, resetOnComplete: false, resetOnRefCountZero: false }). Details: https://rxjs.dev/deprecations/multicasting

function publishReplay<T>(
bufferSize?: number,
windowTime?: number,
timestampProvider?: TimestampProvider,
): MonoTypeOperatorFunction<T>;
function publishReplay<T, O extends ObservableInput<any>>(
bufferSize: number | undefined,
windowTime: number | undefined,
selector: (shared: Observable<T>) => O,
timestampProvider?: TimestampProvider,
): OperatorFunction<T, ObservedValueOf<O>>;
function publishReplay<T, O extends ObservableInput<any>>(
bufferSize: number | undefined,
windowTime: number | undefined,
selector: undefined,
timestampProvider: TimestampProvider,
): OperatorFunction<T, ObservedValueOf<O>>;
§
publishReplay<T>(bufferSize?: number, windowTime?: number, timestampProvider?: TimestampProvider): MonoTypeOperatorFunction<T>
[src]

Creates a ConnectableObservable that uses a ReplaySubject internally.

§Type Parameters

§Parameters

§
bufferSize?: number optional
[src]

The buffer size for the underlying ReplaySubject.

§
windowTime?: number optional
[src]

The window time for the underlying ReplaySubject.

§
timestampProvider?: TimestampProvider optional
[src]

The timestamp provider for the underlying ReplaySubject.

§
publishReplay<T, O extends ObservableInput<any>>(bufferSize: number | undefined, windowTime: number | undefined, selector: (shared: Observable<T>) => O, timestampProvider?: TimestampProvider): OperatorFunction<T, ObservedValueOf<O>>
[src]

Creates an observable, that when subscribed to, will create a ReplaySubject, and pass an observable from it (using asObservable) to the selector function, which then returns an observable that is subscribed to before "connecting" the source to the internal ReplaySubject.

Since this is deprecated, for additional details see the documentation for connect.

§Type Parameters

§
O extends ObservableInput<any>
[src]

§Parameters

§
bufferSize: number | undefined
[src]

The buffer size for the underlying ReplaySubject.

§
windowTime: number | undefined
[src]

The window time for the underlying ReplaySubject.

§
selector: (shared: Observable<T>) => O
[src]

A function used to setup the multicast.

§
timestampProvider?: TimestampProvider optional
[src]

The timestamp provider for the underlying ReplaySubject.

§
publishReplay<T, O extends ObservableInput<any>>(bufferSize: number | undefined, windowTime: number | undefined, selector: undefined, timestampProvider: TimestampProvider): OperatorFunction<T, ObservedValueOf<O>>
[src]

Creates a ConnectableObservable that uses a ReplaySubject internally.

§Type Parameters

§
O extends ObservableInput<any>
[src]

§Parameters

§
bufferSize: number | undefined
[src]

The buffer size for the underlying ReplaySubject.

§
windowTime: number | undefined
[src]

The window time for the underlying ReplaySubject.

§
selector: undefined
[src]

Passing undefined here determines that this operator will return a ConnectableObservable.

§
timestampProvider: TimestampProvider
[src]

The timestamp provider for the underlying ReplaySubject.