@epikodelabs/streamix

---

@epikodelabs/streamix / src/public-api / ReplaySubject

Type Alias: ReplaySubject<T>

ReplaySubject<T> = Subject<T> & object

Defined in: projects/libraries/streamix/src/lib/subjects/replaySubject.ts:24

ReplaySubject replays a bounded history of values to late subscribers. It buffers up to capacity items and delivers them before continuing with live emissions.

Type Declaration

subscribe()

Call Signature

subscribe(callback): Subscription

Parameters

callback

(value) => any

Returns

Subscription

Call Signature

subscribe(receiver): Subscription

Parameters

receiver

Receiver<T>

Returns

Subscription

Call Signature

subscribe(): Subscription

Returns

Subscription

Call Signature

subscribe(callbackOrReceiver?): Subscription

Parameters

callbackOrReceiver?

Receiver<T> | ((value) => any)

Returns

Subscription

query

query: () => Promise<T>

Returns

Promise<T>

toArray

toArray: () => Promise<T[]>

Returns

Promise<T[]>

Type Parameters

T

T = any