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

Types for defining extensions.

Type declaration

  • Optionalincoming?: ((message: JsonMap, callback: AnyFunction) => 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

  • Optionaloutgoing?: ((message: JsonMap, callback: AnyFunction) => 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