Class EntitySubject<T>

Type Parameters

T extends IdInterface

Hierarchy

StreamBehaviorSubject<T>
- EntitySubject

Index

Constructors

Properties

[IsEntitySubject] appendSubject delete deleted nextChange? nextOnAppend patches teardowns unsubscribed

Accessors

id nextStateChange onDeletion

Methods

activateNextOnAppend addTearDown append getValue isUnsubscribed next toUTF8 unsubscribe

Constructors

constructor

new EntitySubject<T>(item: T, teardown?: TeardownLogic): EntitySubject<T>
Type Parameters
- T extends IdInterface
Parameters
- item: T
- Optional teardown: TeardownLogic
Returns EntitySubject<T>
Inherited from StreamBehaviorSubject.constructor
- Defined in packages/rpc/src/model.ts:42

Properties

[IsEntitySubject]

[IsEntitySubject]: boolean = true

`Readonly` appendSubject

appendSubject: Subject<T> = ...

`Readonly` delete

delete: Subject<boolean> = ...

deleted

deleted: boolean = false

`Protected` `Optional` nextChange

nextChange?: Subject<void>

`Protected` nextOnAppend

nextOnAppend: boolean = false

`Readonly` patches

patches: Subject<EntityPatch> = ...

Patches are in class format.

`Protected` teardowns

teardowns: TeardownLogic[] = []

`Protected` unsubscribed

unsubscribed: boolean = false

Accessors

id

get id(): string | number
Returns string | number
- Defined in packages/rpc/src/model.ts:175

nextStateChange

get nextStateChange(): Promise<undefined | void>
Returns Promise<undefined | void>
Inherited from StreamBehaviorSubject.nextStateChange
- Defined in packages/rpc/src/model.ts:56

onDeletion

get onDeletion(): Observable<void>
Returns Observable<void>
- Defined in packages/rpc/src/model.ts:179

Methods

activateNextOnAppend

activateNextOnAppend(): void
Returns void
Inherited from StreamBehaviorSubject.activateNextOnAppend
- Defined in packages/rpc/src/model.ts:93

addTearDown

addTearDown(teardown: TeardownLogic): void
Parameters
- teardown: TeardownLogic
Returns void
Inherited from StreamBehaviorSubject.addTearDown
- Defined in packages/rpc/src/model.ts:63

append

append(value: T): void
Parameters
- value: T
Returns void
Inherited from StreamBehaviorSubject.append
- Defined in packages/rpc/src/model.ts:124

getValue

getValue(): T
This method differs to BehaviorSubject in the way that this does not throw an error when the subject is closed/unsubscribed.

Returns T
Inherited from StreamBehaviorSubject.getValue
- Defined in packages/rpc/src/model.ts:76

isUnsubscribed

isUnsubscribed(): boolean
Returns boolean
Inherited from StreamBehaviorSubject.isUnsubscribed
- Defined in packages/rpc/src/model.ts:52

next

next(value: undefined | T): void
Parameters
- value: undefined | T
Returns void
Overrides StreamBehaviorSubject.next
- Defined in packages/rpc/src/model.ts:199

toUTF8

toUTF8(): StreamBehaviorSubject<string>
Returns StreamBehaviorSubject<string>
Inherited from StreamBehaviorSubject.toUTF8
- Defined in packages/rpc/src/model.ts:97

unsubscribe

unsubscribe(): void
Returns void
Inherited from StreamBehaviorSubject.unsubscribe
- Defined in packages/rpc/src/model.ts:145

Generated using TypeDoc