Skip to main content

Module source

laminar_connectors::nats

Module source 

Source
Expand description

NATS source: JetStream pull consumer with ack-on-commit, or core subscribe (at-most-once). A background task forwards messages through an mpsc channel; JS message handles are retained until notify_epoch_committed fires, then acked in bulk.

Structs§

NatsSource
NATS source — core and JetStream modes.