get_latest_record/
get_latest_record.rs

1use s2::{
2    client::{ClientConfig, StreamClient},
3    types::{BasinName, ReadLimit, ReadRequest},
4};
5
6#[tokio::main]
7async fn main() -> Result<(), Box<dyn std::error::Error>> {
8    let token = std::env::var("S2_ACCESS_TOKEN")?;
9    let config = ClientConfig::new(token);
10    let basin: BasinName = "my-favorite-basin".parse()?;
11    let stream = "my-favorite-stream";
12    let stream_client = StreamClient::new(config, basin, stream);
13
14    let tail = stream_client.check_tail().await?;
15    if tail == 0 {
16        println!("Empty stream");
17        return Ok(());
18    }
19
20    let latest_seq_num = tail - 1;
21
22    let read_limit = ReadLimit::new().with_count(1);
23    let read_request = ReadRequest::new(latest_seq_num).with_limit(read_limit);
24    let latest_record = stream_client.read(read_request).await?;
25
26    println!("{latest_record:#?}");
27
28    Ok(())
29}

get_latest_record/get_latest_record.rs

get_latest_record/
get_latest_record.rs