delete_stream/
delete_stream.rs

1use s2::{
2    client::{BasinClient, ClientConfig},
3    types::{BasinName, DeleteStreamRequest},
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 basin_client = BasinClient::new(config, basin);
12
13    let stream = "my-favorite-stream";
14
15    let delete_stream_request = DeleteStreamRequest::new(stream);
16
17    basin_client.delete_stream(delete_stream_request).await?;
18
19    Ok(())
20}