async-nats/v0.18.0 & nats/v0.23.0

Overview

This release focuses on fixes and improvements, with addition of ordered Push Consumer for async-nats crate and callback refactor.

async-nats

Breaking Changes

• Refactor callbacks by @Jarema in #595

New callbacks approach is simpler to use. Consider below example:

#[tokio::main]
async fn main() -> std::io::Result<()> {
async_nats::ConnectOptions::new().event_callback(|event| async move {
	// listen on specific event
        if let async_nats::Event::Reconnect = event {
            println!("reconnected");
        }
	// or match for all events
	match event {
		async_nats::Event::Disconnect => println!("disconnected"),
		async_nats::Event::Reconnect => println!("reconnected"),
		async_nats::Event::ClientError(err) => println!("client error occured: {}", err);
	}
}).connect("demo.nats.io").await?;
# Ok(())
}

Added

• Add get_last_raw_message_by_subject to Stream by @caspervonb in #584

• Add ClusterInfo and PeerInfo by @Jarema in #572

• Add ordered push consumer by @Jarema in #574

• Add concurrent example by @Jarema in #580

• Add delete message from stream by @Jarema in #588

• Add Nkey authorization support by @neogenie #593

Fixed

• Fix ordered consumer after discard policy hit by @Jarema in #585
• Fix pull consumer stream method when batch is set to 1 by @Jarema in #590
• Fix reconnect auth deadlock by @caspervonb in #578

nats

Added

• Add cluster to streaminfo/consumerinfo struct by @j13tw in #537

New Contributors

• @j13tw made their first contribution in #537
• @neogenie made their first contribution in #593

Once again, we can thank you enough for your contributions. It helps so much with the development and maintenance of the libraries!

Full Changelog: async-nats/v0.17.0...async-nats/v0.18.0