async-nats 0.49.0

A async Rust NATS client
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

use futures::StreamExt;
use std::time::Duration;
use tokio::time::sleep;

#[tokio::main]
async fn main() -> Result<(), async_nats::Error> {
    let client = async_nats::connect("nats://localhost:4222").await?;

    // Slow responder that takes longer than our timeout
    let mut sub = client.subscribe("service").await?;
    let service_client = client.clone();
    tokio::spawn(async move {
        while let Some(msg) = sub.next().await {
            sleep(Duration::from_secs(5)).await;
            if let Some(reply) = msg.reply {
                service_client.publish(reply, "slow".into()).await.ok();
            }
        }
    });

    // NATS-DOC-START
    // Request with custom timeout.
    // `tokio::time::timeout` returns Ok(request_result) or Err(Elapsed).
    match tokio::time::timeout(
        Duration::from_secs(2),
        client.request("service", "data".into()),
    )
    .await
    {
        // Request succeeded
        Ok(Ok(response)) => {
            println!("Response: {}", String::from_utf8_lossy(&response.payload));
        }
        // Request failed (e.g. no responders)
        Ok(Err(e)) => {
            eprintln!("Request failed: {}", e);
        }
        // Timed out
        Err(_) => {
            println!("Request timed out");
        }
    }
    // NATS-DOC-END

    Ok(())
}