nats.rs icon indicating copy to clipboard operation
nats.rs copied to clipboard

Rust client for NATS, the cloud native messaging system.

Results 98 nats.rs issues
Sort by recently updated
recently updated
newest added

This PR experiments with concrete error types. Feel free to share ideas and feedback.

## Problem Calls to get all keys blocks even when there is a non-zero number of keys in the store. Note that this call always blocks when there are 0...

### Use case Deploying lightweight NATS-based microservices on edge devices is a compelling architecture for many applications and probably represents the most significant architecture of the near future. Some immediate...

enhancement

It turns out `poll_write` could return `Poll::Pending` while `poll_flush` could flush successfully (`Poll::Ready`). This seems like a rare case, although possible in theory. This fixes it by actually making it...

- Expose retry_on_failed_connect option - Debug error field ```rust #[tokio::main] async fn main() -> Result { async_nats::ConnectOptions::new() .retry_on_failed_connect() .connect("demo.nats.io")?; Ok(()) } ```

### Observed behavior We are creating a Stream, then creating a Consumer and finally listening to messages. We are getting this error in our logs. ``` {"message":"Nats error: 'pull request...

defect

Depends on https://github.com/rustls/tokio-rustls/pull/59