fromEventObservable
Callable
Type parameters
- T: EventObject
- TInput: NonReducibleUnknown
Parameters
lazyObservable: (__namedParameters: { input: TInput; self: ActorRef<ObservableSnapshot<T, any>, { type: string }>; system: AnyActorSystem }) => Subscribable<T>
A function that creates an observable that delivers event objects. It receives one argument, an object with the following properties:
input
- Data that was provided to the event observable actorself
- The parent actorsystem
- The actor system to which the event observable actor belongs.
It should return a Subscribable, which is compatible with an RxJS Observable, although RxJS is not required to create them.
Returns ObservableActorLogic<T, TInput>
Creates event observable logic that listens to an observable that delivers event objects.
Event observable actor logic is described by an observable stream of objects. Actors created from event observable logic (“event observable actors”) can:
Sending events to event observable actors will have no effect.