@camera.ui/sdk / observable / ReplaySubject

Class: ReplaySubject<T>

Defined in: observable/index.ts:322

Subject that buffers up to the last bufferSize values, the latest one by default. New subscribers immediately receive every buffered value in order before continuing with live emissions. Pass Infinity to keep everything.

Extends

• Subject<T>

Type Parameters

T

T

Constructors

Constructor

new ReplaySubject<T>(bufferSize?): ReplaySubject<T>

Defined in: observable/index.ts:326

Parameters

bufferSize?

number = 1

Returns

ReplaySubject<T>

Overrides

Subject.constructor

Accessors

closed

Get Signature

get closed(): boolean

Defined in: observable/index.ts:130

Whether complete() has already run.

Returns

boolean

Inherited from

Subject.closed

Methods

asObservable()

asObservable(): Observable<T>

Defined in: observable/index.ts:242

Returns a read-only Observable that mirrors this Subject without exposing next() or complete(). Useful for handing out a public stream while keeping write access internal.

Returns

Observable<T>

Read-only Observable view of this Subject.

Example

const subject = new Subject<number>();
export const events$ = subject.asObservable();

Inherited from

Subject.asObservable

---

complete()

complete(): void

Defined in: observable/index.ts:160

Release every subscriber and lock the Subject. Later next() calls are ignored.

Returns

void

Example

subject.complete();

Inherited from

Subject.complete

---

next()

next(value): void

Defined in: observable/index.ts:342

Append value to the buffer, dropping the oldest entry past bufferSize, then dispatch it.

Parameters

value

T

Value to buffer and multicast.

Returns

void

Example

const last$ = new ReplaySubject<number>(1);
last$.next(42);

Overrides

Subject.next

---

pipe()

Call Signature

pipe(): Observable<T>

Defined in: observable/index.ts:215

Chain operators onto this Subject's read-only view.

Returns

Observable<T>

Observable emitting the transformed values.

Example

subject.pipe(distinctUntilChanged()).subscribe((state) => console.log(state));

Inherited from

Subject.pipe

Call Signature

pipe<A>(op1): Observable<A>

Defined in: observable/index.ts:216

Chain operators onto this Subject's read-only view.

Type Parameters

A

A

Parameters

op1

OperatorFn<T, A>

Returns

Observable<A>

Observable emitting the transformed values.

Example

subject.pipe(distinctUntilChanged()).subscribe((state) => console.log(state));

Inherited from

Subject.pipe

Call Signature

pipe<A, B>(op1, op2): Observable<B>

Defined in: observable/index.ts:217

Chain operators onto this Subject's read-only view.

Type Parameters

A

A

B

B

Parameters

op1

OperatorFn<T, A>

op2

OperatorFn<A, B>

Returns

Observable<B>

Observable emitting the transformed values.

Example

subject.pipe(distinctUntilChanged()).subscribe((state) => console.log(state));

Inherited from

Subject.pipe

Call Signature

pipe<A, B, C>(op1, op2, op3): Observable<C>

Defined in: observable/index.ts:218

Chain operators onto this Subject's read-only view.

Type Parameters

A

A

B

B

C

C

Parameters

op1

OperatorFn<T, A>

op2

OperatorFn<A, B>

op3

OperatorFn<B, C>

Returns

Observable<C>

Observable emitting the transformed values.

Example

subject.pipe(distinctUntilChanged()).subscribe((state) => console.log(state));

Inherited from

Subject.pipe

Call Signature

pipe<A, B, C, D>(op1, op2, op3, op4): Observable<D>

Defined in: observable/index.ts:219

Chain operators onto this Subject's read-only view.

Type Parameters

A

A

B

B

C

C

D

D

Parameters

op1

OperatorFn<T, A>

op2

OperatorFn<A, B>

op3

OperatorFn<B, C>

op4

OperatorFn<C, D>

Returns

Observable<D>

Observable emitting the transformed values.

Example

subject.pipe(distinctUntilChanged()).subscribe((state) => console.log(state));

Inherited from

Subject.pipe

Call Signature

pipe<A, B, C, D, E>(op1, op2, op3, op4, op5): Observable<E>

Defined in: observable/index.ts:220

Chain operators onto this Subject's read-only view.

Type Parameters

A

A

B

B

C

C

D

D

E

E

Parameters

op1

OperatorFn<T, A>

op2

OperatorFn<A, B>

op3

OperatorFn<B, C>

op4

OperatorFn<C, D>

op5

OperatorFn<D, E>

Returns

Observable<E>

Observable emitting the transformed values.

Example

subject.pipe(distinctUntilChanged()).subscribe((state) => console.log(state));

Inherited from

Subject.pipe

---

subscribe()

subscribe(callback): Disposable

Defined in: observable/index.ts:363

Replay the buffered values in order, then register callback for live emissions.

Parameters

callback

(value) => void

Receiver invoked once per emitted value.

Returns

Disposable

Disposable that unregisters the callback.

Example

const sub = last$.subscribe((value) => console.log(value));

Overrides

Subject.subscribe