Class ObservableNodeBase<T>

Base class for creating observable chains.

Type Parameters

Hierarchy

ObservableBase<T>
- ObservableNodeBase

Implements

Observer<T>

Index

Constructors

constructor

Methods

_getSubscribers _onCompleted _onDispose _onError _onNext _unsubscribeAll onCompleted onError onNext subscribe unsubscribe unsubscribeAll

Constructors

constructor

new ObservableNodeBase<T>(): ObservableNodeBase<T>
Type Parameters
- T
Returns ObservableNodeBase<T>
Inherited from ObservableBase.constructor
- Defined in SubscribableBase.ts:23

Methods

`Protected` _getSubscribers

_getSubscribers(): undefined | ExtendedIterable<Observer<T>>
Returns undefined | ExtendedIterable<Observer<T>>
Inherited from ObservableBase._getSubscribers
- Defined in SubscribableBase.ts:71

`Protected` _onCompleted

_onCompleted(): void
Returns void
Inherited from ObservableBase._onCompleted
- Defined in ObservableBase.ts:63

`Protected` _onDispose

_onDispose(): void
Returns void
Inherited from ObservableBase._onDispose
- Defined in SubscribableBase.ts:93

`Protected` _onError

_onError(error: unknown): void
Parameters
- error: unknown
Returns void
Inherited from ObservableBase._onError
- Defined in ObservableBase.ts:55

`Protected` _onNext

_onNext(value: T): void
Parameters
- value: T
Returns void
Inherited from ObservableBase._onNext
- Defined in ObservableBase.ts:47

`Protected` _unsubscribeAll

_unsubscribeAll(): undefined
Returns undefined
Inherited from ObservableBase._unsubscribeAll
- Defined in SubscribableBase.ts:76
_unsubscribeAll(returnSubscribers: false): undefined
Parameters
- returnSubscribers: false
Returns undefined
Inherited from ObservableBase._unsubscribeAll
- Defined in SubscribableBase.ts:77
_unsubscribeAll(returnSubscribers: true): undefined | Observer<T>[]
Parameters
- returnSubscribers: true
Returns undefined | Observer<T>[]
Inherited from ObservableBase._unsubscribeAll
- Defined in SubscribableBase.ts:78
_unsubscribeAll(returnSubscribers: boolean): undefined | Observer<T>[]
Parameters
- returnSubscribers: boolean
Returns undefined | Observer<T>[]
Inherited from ObservableBase._unsubscribeAll
- Defined in SubscribableBase.ts:79

onCompleted

onCompleted(): void
Returns void
Implementation of Observer.onCompleted
- Defined in ObservableNodeBase.ts:28

onError

onError(error: unknown): void
Parameters
- error: unknown
Returns void
Implementation of Observer.onError
- Defined in ObservableNodeBase.ts:23

onNext

onNext(value: T): void
Parameters
- value: T
Returns void
Implementation of Observer.onNext
- Defined in ObservableNodeBase.ts:18

subscribe(subscriber: Observer<T>): default
Accepts TSubscriber (observer) and returns a Subscription that can be disposed of. The dispose method is scope independent and can be called out of context and still cancel the subscription.

Returns
Parameters
- subscriber: Observer<T>
Returns default
Inherited from ObservableBase.subscribe
- Defined in ObservableBase.ts:21
subscribe(subscriber: Action<T>, onError?: Action<any>, onCompleted?: Closure): default
Parameters
- subscriber: Action<T>
- Optional onError: Action<any>
- Optional onCompleted: Closure
Returns default
Inherited from ObservableBase.subscribe
- Defined in ObservableBase.ts:23

unsubscribe

unsubscribe(subscriber: Observer<T>): void
Unsubscribes the TSubscriber (observer).
Parameters
- subscriber: Observer<T>
Returns void
Inherited from ObservableBase.unsubscribe
- Defined in SubscribableBase.ts:58

unsubscribeAll

unsubscribeAll(): void
Cancels (disposes) all subscriptions.

Returns void
Inherited from ObservableBase.unsubscribeAll
- Defined in SubscribableBase.ts:66

Class ObservableNodeBase<T>

Type Parameters

T

Hierarchy

Implements

Index

Constructors

Methods

Constructors

constructor

Type Parameters

T

Returns ObservableNodeBase<T>

Methods

Protected _getSubscribers

Returns undefined | ExtendedIterable<Observer<T>>

Protected _onCompleted

Returns void

Protected _onDispose

Returns void

Protected _onError

Parameters

error: unknown

Returns void

Protected _onNext

Parameters

value: T

Returns void

Protected _unsubscribeAll

Returns undefined

Parameters

returnSubscribers: false

Returns undefined

Parameters

returnSubscribers: true

Returns undefined | Observer<T>[]

Parameters

returnSubscribers: boolean

Returns undefined | Observer<T>[]

onCompleted

Returns void

onError

Parameters

error: unknown

Returns void

onNext

Parameters

value: T

Returns void

subscribe

Returns

Parameters

subscriber: Observer<T>

Returns default

Parameters

subscriber: Action<T>

Optional onError: Action<any>

Optional onCompleted: Closure

Returns default

unsubscribe

Parameters

subscriber: Observer<T>

Returns void

unsubscribeAll

Returns void

Settings

Member Visibility

Theme

`Protected` _getSubscribers

`Protected` _onCompleted

`Protected` _onDispose

`Protected` _onError

`Protected` _onNext

`Protected` _unsubscribeAll

`Optional` onError: Action<any>

`Optional` onCompleted: Closure