Class InjectableNopeEventEmitter<T, S, G>

RsJX based Observable.

Contains additional Functionalities like:

property with the current value
function to publish values. (wrapper for next)
enables performing a subscription with synced call or a immediate call.

Type Parameters

T
S = T
G = T

Hierarchy

NopeEventEmitter<T, S, G>
- InjectableNopeEventEmitter

Index

Constructors

constructor

new InjectableNopeEventEmitter<T, S, G>(_options?): InjectableNopeEventEmitter<T, S, G>
Type Parameters
- T
- S = T
- G = T
Parameters
- _options: TSubjectOptions = {}
Returns InjectableNopeEventEmitter<T, S, G>
Inherited from NopeEventEmitter.constructor
- Defined in lib/eventEmitter/nopeEventEmitter.ts:448

Properties

_subscriptions

_subscriptions: Set<(() => void)> = ...

A Set containing the Subscriptions

disablePublishing

disablePublishing: boolean = false

Flag to Disable Publishing

`Readonly` id

id: string = ...

An id of the Observable. This might be usefull for debugging.

options

options: any = ...

options.

setter

setter: ((value, options?) => {
data: T;
valid: boolean;
}) = null

Type declaration

- (value, options?): {
  data: T;
  valid: boolean;
  }
- Function to specify a Setter
  Parameters
  - value: S
  - Optional options: Partial<IEventAdditionalData>
  Returns {
  data: T;
  valid: boolean;
  }
  - data: T
  - valid: boolean

Accessors

getter

get getter(): ((value) => G)
Returns ((value) => G)
- - (value): G
  - Parameters
    - value: T
    Returns G
Inherited from NopeEventEmitter.getter
- Defined in lib/eventEmitter/nopeEventEmitter.ts:72
set getter(_getter): void
Parameters
- _getter: ((value) => G)
  - - (value): G
    - Parameters
      
      value: T
      
      Returns G
Returns void
Inherited from NopeEventEmitter.getter
- Defined in lib/eventEmitter/nopeEventEmitter.ts:76

hasSubscriptions

get hasSubscriptions(): boolean
Flag, showing if there exists any subscription this particular observer.

Returns boolean
Inherited from NopeEventEmitter.hasSubscriptions
- Defined in lib/eventEmitter/nopeEventEmitter.ts:440

observerLength

get observerLength(): number
Returns the amout of interessed Subscribers / Observers.

Returns number
Inherited from NopeEventEmitter.observerLength
- Defined in lib/eventEmitter/nopeEventEmitter.ts:444

Methods

dispose

dispose(): void
Function, used to dispose the observable. Every item will be unsubscribed.

Returns void
Inherited from NopeEventEmitter.dispose
- Defined in lib/eventEmitter/nopeEventEmitter.ts:159

emit

emit(value, options?): boolean
Function to update the Content
Parameters
- value: S
  
  The content
- options: Partial<IEventAdditionalData> = {}
Returns boolean
Inherited from NopeEventEmitter.emit
- Defined in lib/eventEmitter/nopeEventEmitter.ts:80

enhancedSubscription

enhancedSubscription<K>(next, options?): Subscription
Create an enhanced Subscription of the Observable. Use the Pipes, to Define what should be subscribed.
Type Parameters
- K
Parameters
- next: ((data) => void)
  
  The Next Function, used to transmit changes
  - - (data): void
    - Parameters
      
      data: K
      
      Returns void
- options: {
      pipe?: IPipe<T | G, K>;
      scope?: {
          [index: string]: any;
      };
  } = {}
  
  The Options, used to determine the Enhancements.
  - Optional pipe?: IPipe<T | G, K>
  - Optional scope?: {
    [index: string]: any;
    }
    - [index: string]: any
Returns Subscription
Inherited from NopeEventEmitter.enhancedSubscription
- Defined in lib/eventEmitter/nopeEventEmitter.ts:294

once

once(func, options?): INopeObserver
Creates a Subscription for the value of the Observable. After one Update the Value will be deleted
Parameters
- func: IEventCallback<G, IEventAdditionalData>
  
  Function which is called when new Datas are pushed
- Optional options: INopeSubscriptionOptions
  
  Additional Options
Returns INopeObserver
Inherited from NopeEventEmitter.once
- Defined in lib/eventEmitter/nopeEventEmitter.ts:327

subscribe(observer, options?): INopeObserver
A Function to subscribe to updates of the Observable.
Parameters
- observer: INopePartialObserver<G, IEventAdditionalData> | IEventCallback<G, IEventAdditionalData>
  
  The Observer. Could be a Function or a Partial Observer.
- options: INopeSubscriptionOptions = ...
  
  Additional Options.
Returns INopeObserver
Inherited from NopeEventEmitter.subscribe
- Defined in lib/eventEmitter/nopeEventEmitter.ts:176

waitFor

waitFor(testCallback?, options?): Promise<G>
Async Function to Wait for an Update
Parameters
- testCallback: IWaitForCallback<G, IEventAdditionalData> = ...
- options: INopeWaitForObservableChangeOptions = ...
  
  Additional Options for the Wait Function.
Returns Promise<G>
Inherited from NopeEventEmitter.waitFor
- Defined in lib/eventEmitter/nopeEventEmitter.ts:351

waitForUpdate

waitForUpdate(options?): Promise<G>
Async Function to Wait for an Update
Parameters
- Optional options: INopeSubscriptionOptions
  
  Additional Options for the Wait Function.
Returns Promise<G>
Inherited from NopeEventEmitter.waitForUpdate
- Defined in lib/eventEmitter/nopeEventEmitter.ts:427

Class InjectableNopeEventEmitter<T, S, G>

Type Parameters

T

S = T

G = T

Hierarchy

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

Type Parameters

T

S = T

G = T

Parameters

_options: TSubjectOptions = {}

Returns InjectableNopeEventEmitter<T, S, G>

Properties

_subscriptions

disablePublishing

Readonly id

options

setter

Type declaration

Parameters

value: S

Optional options: Partial<IEventAdditionalData>

Returns { data: T; valid: boolean; }

data: T

valid: boolean

Accessors

getter

Returns ((value) => G)

Parameters

value: T

Returns G

Parameters

_getter: ((value) => G)

Parameters

value: T

Returns G

Returns void

hasSubscriptions

Returns boolean

observerLength

Returns number

Methods

dispose

Returns void

emit

Parameters

value: S

options: Partial<IEventAdditionalData> = {}

Returns boolean

enhancedSubscription

Type Parameters

K

Parameters

next: ((data) => void)

Parameters

data: K

Returns void

options: { pipe?: IPipe<T | G, K>; scope?: { [index: string]: any; }; } = {}

Optional pipe?: IPipe<T | G, K>

Optional scope?: { [index: string]: any; }

[index: string]: any

Returns Subscription

once

Parameters

func: IEventCallback<G, IEventAdditionalData>

Optional options: INopeSubscriptionOptions

Returns INopeObserver

subscribe

Parameters

observer: INopePartialObserver<G, IEventAdditionalData> | IEventCallback<G, IEventAdditionalData>

options: INopeSubscriptionOptions = ...

Returns INopeObserver

`Readonly` id

`Optional` options: Partial<IEventAdditionalData>

Returns {
data: T;
valid: boolean;
}

options: {
pipe?: IPipe<T | G, K>;
scope?: {
[index: string]: any;
};
} = {}

`Optional` pipe?: IPipe<T | G, K>

`Optional` scope?: {
[index: string]: any;
}

`Optional` options: INopeSubscriptionOptions

`Optional` options: INopeSubscriptionOptions