StreamingExtension: {
    incoming?: ((message, callback) => void);
    outgoing?: ((message, callback) => void);
}

Types for defining extensions.

Type declaration

  • Optional incoming?: ((message, callback) => void)

    Extension for the incoming message.

      • (message, callback): void
      • Parameters

        • message: JsonMap

          The message.

        • callback: AnyFunction

          The callback to invoke after the message is processed.

        Returns void

  • Optional outgoing?: ((message, callback) => void)

    Extension for outgoing message.

      • (message, callback): void
      • Parameters

        • message: JsonMap

          The message.

        • callback: AnyFunction

          The callback to invoke after the message is processed.

        Returns void