An incremunica Stream Sources Query Source Identify Actor.

Hierarchy

  • ActorQuerySourceIdentify
    • ActorQuerySourceIdentifyStream

Constructors

Properties

beforeActors: Actor<
    IActionQuerySourceIdentify,
    IActorTest,
    IActorQuerySourceIdentifyOutput,
>[]

Actor that must be registered in the bus before this actor.

bus: Bus<
    Actor<
        IActionQuerySourceIdentify,
        IActorTest,
        IActorQuerySourceIdentifyOutput,
    >,
    IActionQuerySourceIdentify,
    IActorTest,
    IActorQuerySourceIdentifyOutput,
>

The bus this actor subscribes to.

mediatorContextPreprocess: MediatorContextPreprocess
mediatorRdfMetadataAccumulate: MediatorRdfMetadataAccumulate
name: string

The name for this actor.

{<rdf:subject>}

Methods

  • Parameters

    • context: IActionContext
    • Optionaldata: () => any

    Returns any

  • Parameters

    • context: IActionContext
    • message: string
    • Optionaldata: () => any

    Returns void

  • Parameters

    • context: IActionContext
    • message: string
    • Optionaldata: () => any

    Returns void

  • Parameters

    • context: IActionContext
    • message: string
    • Optionaldata: () => any

    Returns void

  • Parameters

    • context: IActionContext
    • message: string
    • Optionaldata: () => any

    Returns void

  • Parameters

    • context: IActionContext
    • message: string
    • Optionaldata: () => any

    Returns void

  • Parameters

    • context: IActionContext
    • message: string
    • Optionaldata: () => any

    Returns void

  • Run the given action on this actor.

    In most cases, this method should not be called directly. Instead, #runObservable should be called.

    Parameters

    • action: IActionQuerySourceIdentify

      The action to run.

    Returns Promise<IActorQuerySourceIdentifyOutput>

    A promise that resolves to the run result.

  • Run the given action on this actor AND invokes the Bus#onRun method.

    Parameters

    • action: IActionQuerySourceIdentify

      The action to run.

    • sideData: undefined

    Returns Promise<IActorQuerySourceIdentifyOutput>

    A promise that resolves to the run result.

  • Check if this actor can run the given action, without actually running it.

    Parameters

    • action: IActionQuerySourceIdentify

      The action to test.

    Returns Promise<TestResult<IActorTest>>

    A promise that resolves to the test result.

  • Get the logger from the given context.

    Parameters

    • context: IActionContext

      An optional context.

    Returns undefined | Logger

    The logger or undefined.