Skip to content

Release async-nats v0.22.0

Compare
Choose a tag to compare
@Jarema Jarema released this 08 Nov 22:05
· 538 commits to main since this release

Overview

This release introduces a number of changes and two breaking changes:

JetStream publish

Used to return ack:

let ack = jetstream.publish().await.unwrap();

But while adding publish that does not wait for an acknowledgement before returning,
we realized that we can leverage IntoFuture, so the new api is:

// This publishes the message, but do not wait until ack is received.
let future_ack = jetstream.publish().await.unwrap();
// to receive the acknowledge, `await()` the returned value:
let ack = future_ack.await().unwrap();

Event logging

After adding the initial retry on connect option, Event::Reconnect didn't make much sense.
Hence it was renamed to Event::Connected, which describes the current state without implications about the previous one.
For consistency, Event::Disconnect was renamed to Event::Disconnected.

Breaking changes

Added

  • Add support for mirrors and sources in Key Value Store by @Jarema in #676
  • Add sources and mirror to stream config by @Jarema in #673
  • Add retry on initial connect by @Jarema in #662
  • Add docs to client methods by @Jarema in #664
  • Add license to nats-server wrapper by @Jarema in #704

Fixed

Changed

New Contributors

Full Changelog: async-nats/v0.21.0...async-nats/v0.22.0