@camera.ui/sdk / observable / ReplaySubject

Class: ReplaySubject<T>

Defined in: observable/index.ts:232

Subject that buffers up to the last bufferSize values (configurable, defaults to unbounded). New subscribers immediately receive every buffered value in order before continuing with live emissions.

Extends

• Subject<T>

Type Parameters

T

T

Constructors

Constructor

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

Defined in: observable/index.ts:236

Parameters

bufferSize?

number = Infinity

Returns

ReplaySubject<T>

Overrides

Subject.constructor

Accessors

closed

Get Signature

get closed(): boolean

Defined in: observable/index.ts:106

Returns

boolean

Inherited from

Subject.closed

Methods

asObservable()

asObservable(): Observable<T>

Defined in: observable/index.ts:186

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:117

Returns

void

Inherited from

Subject.complete

---

next()

next(value): void

Defined in: observable/index.ts:241

Parameters

value

T

Returns

void

Overrides

Subject.next

---

pipe()

Call Signature

pipe(): Observable<T>

Defined in: observable/index.ts:159

Returns

Observable<T>

Inherited from

Subject.pipe

Call Signature

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

Defined in: observable/index.ts:160

Type Parameters

A

A

Parameters

op1

OperatorFn<T, A>

Returns

Observable<A>

Inherited from

Subject.pipe

Call Signature

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

Defined in: observable/index.ts:161

Type Parameters

A

A

B

B

Parameters

op1

OperatorFn<T, A>

op2

OperatorFn<A, B>

Returns

Observable<B>

Inherited from

Subject.pipe

Call Signature

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

Defined in: observable/index.ts:162

Type Parameters

A

A

B

B

C

C

Parameters

op1

OperatorFn<T, A>

op2

OperatorFn<A, B>

op3

OperatorFn<B, C>

Returns

Observable<C>

Inherited from

Subject.pipe

Call Signature

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

Defined in: observable/index.ts:163

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>

Inherited from

Subject.pipe

Call Signature

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

Defined in: observable/index.ts:164

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>

Inherited from

Subject.pipe

---

subscribe()

subscribe(callback): Disposable

Defined in: observable/index.ts:250

Parameters

callback

(value) => void

Returns

Disposable

Overrides

Subject.subscribe