Class DuplexHandler<Container, Input, Output>Abstract

handle

• handle(input, cancel, meta, ctx): AsyncIterableIterator<Output>

• Note that if the output has an error, the handler will not see this as an error. If you need to handle any clean up it should be handled in a finally block and check the abort signal for potential errors.

  Parameters

  • input: AsyncIterableIterator<Input>

  • cancel: ((reason?) => void)

    • • (reason?): void

      • Parameters

        • Optional reason: any

        Returns void

  • meta: undefined | Record<string, JSONValue>

  • ctx: ContextTimed

  Returns AsyncIterableIterator<Output>