1#![doc = include_str!("README.md")]
2#![forbid(unsafe_code)]
3
4mod broker;
5mod convert;
6mod error;
7#[cfg(feature = "testing")]
8mod in_process;
9mod jetstream;
10mod message;
11mod publisher;
12mod request_reply;
13mod subject;
14mod subscriber;
15
16pub mod context;
17pub mod prelude;
18
19pub use broker::{ClosedNatsBroker, ConnectedNatsBroker, NatsBroker};
20pub use error::NatsError;
21pub use jetstream::{
22 JetStreamOptions, JetStreamPublish, JetStreamPublishSteps, JetStreamPublisher, PublishAck,
23};
24pub use message::{CoreMessage, JetStreamMessage, NatsMessage, PARTITION_KEY_HEADER};
25pub use publisher::{NatsPublish, NatsPublishPolicy, NatsPublisher};
26pub use subject::{
27 CoreSubject, CoreWildcard, DeliverPolicy, JetStreamSubject, NatsSubscription, NonZeroDuration,
28};
29pub use subscriber::NatsSubscriber;