Skip to content

@camera.ui/sdk / observable / Subject

Class: Subject<T>

Defined in: observable/index.ts:101

Multicast value source.

Calls to next(value) are dispatched synchronously to every active subscriber. complete() releases all subscribers and locks the Subject so further next() calls become no-ops. subscribe() returns a Disposable for individual cleanup.

Extended by

Type Parameters

T

T

Constructors

Constructor

new Subject<T>(): Subject<T>

Returns

Subject<T>

Accessors

closed

Get Signature

get closed(): boolean

Defined in: observable/index.ts:106

Returns

boolean

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

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

complete()

complete(): void

Defined in: observable/index.ts:117

Returns

void


next()

next(value): void

Defined in: observable/index.ts:110

Parameters

value

T

Returns

void


pipe()

Call Signature

pipe(): Observable<T>

Defined in: observable/index.ts:159

Returns

Observable<T>

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>

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>

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>

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>

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>


subscribe()

subscribe(callback): Disposable

Defined in: observable/index.ts:149

Parameters

callback

(value) => void

Returns

Disposable