Class Message

constructor

• new Message(
      value: Buffer,
      options?: sessionReduce.MessageOptions,
  ): sessionReduce.Message

  Create a new session reduce output message.

  Parameters

  • value: Buffer

    The message payload as a Buffer

  • Optionaloptions: sessionReduce.MessageOptions

    Optional keys and tags

  Returns sessionReduce.Message

Optionalkeys

Optionaltags

value

StatictoDrop

• toDrop(): sessionReduce.Message

  Create a drop message that will be discarded.

  Returns sessionReduce.Message

  A message marked for dropping