From d63b76b71ebd51ccd2a134d3dba5838082708ca8 Mon Sep 17 00:00:00 2001 From: Mikhail Grachev Date: Fri, 31 Mar 2023 18:56:13 +0300 Subject: [PATCH] Remove extra whitespaces Signed-off-by: Mikhail Grachev --- async-nats/CHANGELOG.md | 12 ++++++------ async-nats/src/jetstream/consumer/pull.rs | 4 ++-- async-nats/src/jetstream/consumer/push.rs | 2 +- async-nats/src/jetstream/context.rs | 2 +- async-nats/src/lib.rs | 2 +- nats/CHANGELOG.md | 2 +- 6 files changed, 12 insertions(+), 12 deletions(-) diff --git a/async-nats/CHANGELOG.md b/async-nats/CHANGELOG.md index 046574c99..59d7f4ef2 100644 --- a/async-nats/CHANGELOG.md +++ b/async-nats/CHANGELOG.md @@ -37,7 +37,7 @@ All enums implement `PartialEq` for more straightforward assertions. Once again, thanks @abalmos & @NorbertBodziony for helping out with replicating the issues around fetch. Also big thanks @paolobarbolini for the very detailed report and reproduction for TLS issue and @n1ghtmare for debugging Windows related issues. -Your contributions are invaluable to the NATS ecosystem. +Your contributions are invaluable to the NATS ecosystem. **Full Changelog**: https://github.com/nats-io/nats.rs/compare/async-nats/v0.28.0...async-nats/v0.29.0 @@ -126,7 +126,7 @@ The main focus of this release is Service API with support for multiple endpoint * Explicitly delete consumer after iterating over kv keys by @Jarema in https://github.com/nats-io/nats.rs/pull/818 ## Fixed -* Fix key listing for async client to match Go client by @thomastaylor312 in https://github.com/nats-io/nats.rs/pull/792 +* Fix key listing for async client to match Go client by @thomastaylor312 in https://github.com/nats-io/nats.rs/pull/792 ## New Contributors @@ -225,7 +225,7 @@ It also introduces a breaking change, as not all `publish()` methods did return ## New Contributors * @c0d3x42 made their first contribution in https://github.com/nats-io/nats.rs/pull/716 -* @piotrpio made their first contribution in https://github.com/nats-io/nats.rs/pull/728 +* @piotrpio made their first contribution in https://github.com/nats-io/nats.rs/pull/728 **Full Changelog**: https://github.com/nats-io/nats.rs/compare/async-nats/v0.22.1...async-nats/v0.23.0 @@ -335,9 +335,9 @@ This release's highlight is added support for Object Store. This release focuses on KV and 2.9 nats-server features. ## Added -* Add Key Value by @Jarema and @caspervonb in https://github.com/nats-io/nats.rs/pull/586 +* Add Key Value by @Jarema and @caspervonb in https://github.com/nats-io/nats.rs/pull/586 * Add Direct get by @Jarema in https://github.com/nats-io/nats.rs/pull/636 -* Add timeout to request & request builder by @Jarema in https://github.com/nats-io/nats.rs/pull/616 +* Add timeout to request & request builder by @Jarema in https://github.com/nats-io/nats.rs/pull/616 * Add memory storage option to consumers by @Jarema in https://github.com/nats-io/nats.rs/pull/638 * Add Consumer name by @Jarema in https://github.com/nats-io/nats.rs/pull/637 @@ -346,7 +346,7 @@ This release focuses on KV and 2.9 nats-server features. ## What's Changed * Headers refactor by @Jarema in https://github.com/nats-io/nats.rs/pull/629 -* Use new Consumer API by @Jarema in https://github.com/nats-io/nats.rs/pull/637 +* Use new Consumer API by @Jarema in https://github.com/nats-io/nats.rs/pull/637 **Full Changelog**: https://github.com/nats-io/nats.rs/compare/async-nats/v0.19.0...async-nats/v0.20.0 # 0.19.0 diff --git a/async-nats/src/jetstream/consumer/pull.rs b/async-nats/src/jetstream/consumer/pull.rs index 0b31f9c8b..3ee1c0ee4 100644 --- a/async-nats/src/jetstream/consumer/pull.rs +++ b/async-nats/src/jetstream/consumer/pull.rs @@ -510,7 +510,7 @@ impl Stream { let mut pending_reset = false; tokio::select! { - _ = context.client.state.changed() => { + _ = context.client.state.changed() => { let state = context.client.state.borrow().to_owned(); if !(state == crate::connection::State::Connected && prev_state != State::Connected) { @@ -757,7 +757,7 @@ impl futures::Stream for Stream { }))); } status => { - debug!("received unknown message: {:?}", message); + debug!("received unknown message: {:?}", message); return Poll::Ready(Some(Err(Box::new(std::io::Error::new( std::io::ErrorKind::Other, format!( diff --git a/async-nats/src/jetstream/consumer/push.rs b/async-nats/src/jetstream/consumer/push.rs index 7189521f8..3794a9c53 100644 --- a/async-nats/src/jetstream/consumer/push.rs +++ b/async-nats/src/jetstream/consumer/push.rs @@ -447,7 +447,7 @@ impl Consumer { let current_state = state.borrow().to_owned(); tokio::select! { _ = context.client.state.changed() => { - if state.borrow().to_owned() != State::Connected || current_state == State::Connected { + if state.borrow().to_owned() != State::Connected || current_state == State::Connected { continue; } debug!("reconnected. trigger consumer recreation"); diff --git a/async-nats/src/jetstream/context.rs b/async-nats/src/jetstream/context.rs index e83bdb999..7227498ff 100644 --- a/async-nats/src/jetstream/context.rs +++ b/async-nats/src/jetstream/context.rs @@ -346,7 +346,7 @@ impl Context { } } - /// Create a stream with the given configuration on the server if it is not present. Returns a handle to the stream on the server. + /// Create a stream with the given configuration on the server if it is not present. Returns a handle to the stream on the server. /// /// Note: This does not validate if the Stream on the server is compatible with the configuration passed in. /// diff --git a/async-nats/src/lib.rs b/async-nats/src/lib.rs index e16778010..58ada931b 100644 --- a/async-nats/src/lib.rs +++ b/async-nats/src/lib.rs @@ -19,7 +19,7 @@ //! system for cloud native applications, `IoT` messaging, and microservices //! architectures. //! -//! For sync API refer +//! For sync API refer //! //! For more information see [https://nats.io/]. //! diff --git a/nats/CHANGELOG.md b/nats/CHANGELOG.md index 06cc5b299..95b3f3cbc 100644 --- a/nats/CHANGELOG.md +++ b/nats/CHANGELOG.md @@ -141,7 +141,7 @@ This release brings a lot of changes and refactors among which the highlights ar * Add support for JetStream publishing by @caspervonb in https://github.com/nats-io/nats.rs/pull/248 * Add `error_callback` by @derekcollison in https://github.com/nats-io/nats.rs/pull/253 * Add `get_message` to JetStream context by @caspervonb in https://github.com/nats-io/nats.rs/pull/267 -* Add `get_last_message` to JetStream context by @caspervonb in https://github.com/nats-io/nats.rs/pull/267 +* Add `get_last_message` to JetStream context by @caspervonb in https://github.com/nats-io/nats.rs/pull/267 * Add option `retry_on_failed_connect` by @pozsgaic in https://github.com/nats-io/nats.rs/pull/223 * Add support for different .pem contents by @Jarema https://github.com/nats-io/nats.rs/pull/280 * Introduce ServerAddress https://github.com/nats-io/nats.rs/pull/276