Module async_nats::jetstream::message

A wrapped crate::Message with JetStream related methods.

Structs

• Acker
  A lightweight struct useful for decoupling message contents and the ability to ack it.
• Info
  Information about a received message
• Message
• StreamMessage
  A message received directly from the stream, without leveraging a consumer.

Enums

• AckKind
  The kinds of response used for acknowledging a processed message.
• StreamMessageErrorKind

Type Aliases

• StreamMessageError
  Error returned when library is unable to parse message got directly from the stream.