CLEAR

EventSource


The EventSource class provides methods for monitoring signals.

Properties

This class exposes no properties.

Methods

MethodDescription

select

select(property: string): EventSource

Converts event source by selecting a property in the event object. Events without specified property are ignored.

skip

skip(count: number): EventSource

Yields a filtered event source: the first count events from the original source are dropped, and subsequent ones signaled.

subscribe

subscribe(callback: (event: mixed) => void): Subscription

Sets a callback for the event source. The callback will be invoked every time an event is emitted from this EventSource.

See Also: Subscription.unsubscribe.

Note: subscribe and subscribeOnNext functions are completely equivalent.

subscribeOnNext

subscribeOnNext(callback: (event: mixed) => void): Subscription

Sets a callback for the event source. The callback will be invoked every time an event is emitted from this EventSource.

See Also: Subscription.unsubscribe.

Note: subscribe and subscribeOnNext functions are completely equivalent.

subscribeWithSnapshot

subscribeWithSnapshot(snapshot: { [string]: Signal}, callback: (event: mixed, snapshot: mixed) => void): Subscription

Sets a callback for the event source, similar to Subscribe function, but with additional Snapshot parameter. Snapshot is a dictionary of String/Bool/Scalar signals, which will be passed as JSON to the callback function using lastValue from requested signals

take

take(count: number): EventSource

Yields a filtered event source: the first count events from the original source are signaled, and subsequent ones ignored.

valueOf (inherited from ISignal)

valueOf(): void

Throws an error. Signals are not supposed to be implicitly converted to scalar values.

See also: ScalarSignal.add, ScalarSignal.sub, ScalarSignal.mul, ScalarSignal.div