camera.ui Node SDK

Appearance

@camera.ui/sdk / observable / Observable

Class: Observable<T> ​

Defined in: observable/index.ts:50

Cold producer of a push-based value stream.

The producer function passed to the constructor is executed once per subscribe() call, so each subscriber gets its own independent run. subscribe() returns a Disposable that stops the stream and triggers any teardown registered by the producer.

Type Parameters ​

T ​

T

Constructors ​

Constructor ​

new Observable<T>(subscribe): Observable<T>

Defined in: observable/index.ts:54

Parameters ​

subscribe ​

(callback) => Disposable

Returns ​

Observable<T>

Methods ​

pipe() ​

Call Signature ​

pipe(): Observable<T>

Defined in: observable/index.ts:78

Returns ​

Observable<T>

Call Signature ​

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

Defined in: observable/index.ts:79

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

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

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

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

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

Start the producer for this subscriber and route emitted values to callback.

Parameters ​

callback ​

(value) => void

Receiver invoked once per emitted value.

Returns ​

Disposable

Disposable that stops the stream and runs producer teardown.

Example ​

ts
const sub = sensor.onPropertyChanged.subscribe((change) => {
  console.log(change.property, change.value);
});
// later
sub.dispose();