Class ConsumerProcessor<T>

constructor

• new ConsumerProcessor<T>(
      validator: Validator,
      spec: ConsumerProcessorSpec,
      action: ConsumerProcessorAction<T>,
  ): ConsumerProcessor<T>

  Creates a new processor instance.

  Type Parameters

  • T

  Parameters

  • validator: Validator

    The validator instance.

  • spec: ConsumerProcessorSpec

    The spec object.

  • action: ConsumerProcessorAction<T>

    The action function.

  Returns ConsumerProcessor<T>

Readonlyspec

execute

• execute(data: unknown): Promise<void>

  Parameters

  • data: unknown

  Returns Promise<void>