nats.rs
nats.rs copied to clipboard
Rust client for NATS, the cloud native messaging system.
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...
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...
Depends on https://github.com/rustls/tokio-rustls/pull/59
closes #1218