fromObservable() function

Signature:

export declare function fromObservable<TContext, TInput>(observableCreator: ({ input, system }: {
    input: TInput;
    system: AnyActorSystem;
    self: ObservableActorRef<TContext>;
}) => Subscribable<TContext>): ObservableActorLogic<TContext, TInput>;

Parameters

Parameter	Type	Description
observableCreator	({ input, system }: { input: TInput; system: AnyActorSystem; self: ObservableActorRef<TContext>; }) => Subscribable<TContext>

Returns:

ObservableActorLogic<TContext, TInput>