fromEventObservable() function​
Creates event observable logic that listens to an observable that delivers event objects.
Signature:
export declare function fromEventObservable<T extends EventObject, TInput>(lazyObservable: ({ input, system }: {
input: TInput;
system: AnyActorSystem;
self: ObservableActorRef<T>;
}) => Subscribable<T>): ObservableActorLogic<T, TInput>;
Parameters​
Parameter | Type | Description |
---|---|---|
lazyObservable | ({ input, system }: { input: TInput; system: AnyActorSystem; self: ObservableActorRef<T>; }) => Subscribable<T> | A function that creates an observable |
Returns:
ObservableActorLogic<T, TInput>
Event observable logic