watermelon 0.5.0

High level actor based implementation NATS Core and NATS Jetstream client implementation
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

pub use self::consumer_batch::ConsumerBatch;
pub use self::consumer_list::Consumers;
pub use self::consumer_stream::{ConsumerStream, ConsumerStreamError};
pub use self::message::{JetstreamMessage, JetstreamMessageAckError};
pub use self::publish::{
    ClientJetstreamPublish, DoClientJetstreamPublish, DoOwnedClientJetstreamPublish,
    JetstreamPublish, JetstreamPublishBuilder, JetstreamPublishError, OwnedClientJetstreamPublish,
    PubAck,
};
pub use self::stream_list::Streams;

mod consumer_batch;
mod consumer_list;
mod consumer_stream;
mod message;
mod publish;
mod stream_list;