nats.rs

nats.rs copied to clipboard

JS Consumer lost after disconnect/reconnect (0.21)

18

It looks like #224, but I guess with a new api (since the old issue was closed). - [x] Included below version and environment information - [x] Included a [Minimal,...

bbigras

Add flush parameter to publish

2

#### Use Case: Add a flush parameter for low latency use cases that flushes automatically. This is before and after flushing connection after every publish.  #### Proposed Change: Add...

buffalu

async_nats::Error is not std::error::Error

3

Consider this sample: ```rust pub(crate) async fn new( nats_url: &str, subscription_type: EngineSubscriptionType, ) -> anyhow::Result { let client = async_nats::connect(nats_url).await?; let subscription = client .subscribe(Self::topic_from_subscription_type(&subscription_type)) .await?; Ok(Receiver { client, subscription,...

jaskij

Add timeout to request & request builder

1

Jarema

Ability to make client reconnect every second indefinitely

1

#### Use Case: I like the reconnection capabilities of the sync nats client. You can set to keep reconnecting a max number of times (which can be None for infinity)...

chris13524

Introduce a `Subject` type to async-nats

2

Following #222 this introduces the subject type to the new `asnyc-nats` client. It seemed to me that `async-nats` is now mature enough to bring this in again 😄 I adapted...

MattesWhite

caspervonb

Relax the zeroize dependency requirements

1

Hey all I'm running into some dependency conflicts. I was wondering whether if it would be possible to relax the zeroize requirement from 1.4 to support more versioning! If not,...

samsends

Fix jetstream PagedIterator infinite loop

2

On current nats server version (2.8) when a paged request is made to jetstream (e.g. to list the stream names), the page will never be empty, making the last page...

kaizensparc

Jarema