reliably 0.3.7

A fully-featured real-time Rust SDK for Ably pubsub
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

use std::env;

use futures::StreamExt;

use reliably::Result;

#[tokio::main]
async fn main() -> Result<()> {
    let key = env::var("ABLY_API_KEY").expect("ABLY_API_KEY env var must be set");

    let client = reliably::Rest::new(&key)?;

    let channel = client.channels().get("rust-example");

    // Publish 10 messages
    for n in 1..11 {
        println!("Publishing message {}", n);
        channel
            .publish()
            .string(format!("message {}", n))
            .send()
            .await?;
    }

    // Retrieve the history
    let mut pages = channel.history().pages();
    while let Some(Ok(page)) = pages.next().await {
        let msgs = page.items().await?;
        println!("Received page of {} messages", msgs.len());
        for msg in msgs {
            println!("data = {:?}", msg.data);
        }
    }

    Ok(())
}