This PR adds a nats module which holds an API and actor to handle JetStream consumers, filtered views on top of streams.
:rocket:
This description was created by Ellipsis for commit 386af791df07980f9873588de957a70b969c359a
Summary:
This PR introduces a nats module with an actor model for NATS JetStream consumers, including a Nats struct with methods for initialization, subscription, and shutdown.
Key points:
Adds nats module for NATS JetStream consumers.
Implements actor model for handling consumers.
Introduces Nats struct with methods for initialization, subscription, and shutdown.
Implements Nats::new for client and actor initialization.
Implements Nats::subscribe for consumer creation and message handling.
Implements Nats::shutdown for actor shutdown signal.
This PR adds a
nats
module which holds an API and actor to handle JetStream consumers, filtered views on top of streams.Summary:
This PR introduces a
nats
module with an actor model for NATS JetStream consumers, including aNats
struct with methods for initialization, subscription, and shutdown.Key points:
nats
module for NATS JetStream consumers.Nats
struct with methods for initialization, subscription, and shutdown.Nats::new
for client and actor initialization.Nats::subscribe
for consumer creation and message handling.Nats::shutdown
for actor shutdown signal.Generated with :heart: by ellipsis.dev