get_latest_record/
get_latest_record.rs

1use s2::{
2    client::{ClientConfig, StreamClient},
3    types::{BasinName, ReadLimit, ReadRequest, ReadStart},
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 read_limit = ReadLimit::new().with_count(1);
15    let read_request = ReadRequest::new(ReadStart::TailOffset(1)).with_limit(read_limit);
16    let latest_record = stream_client.read(read_request).await?;
17
18    println!("{latest_record:#?}");
19
20    Ok(())
21}

get_latest_record/get_latest_record.rs

get_latest_record/
get_latest_record.rs