teamtalk 6.0.0

TeamTalk SDK for Rust
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

#[cfg(feature = "async")]
use futures::StreamExt;
#[cfg(feature = "async")]
use teamtalk::{Client, Event};

#[cfg(feature = "async")]
fn main() -> teamtalk::Result<()> {
    // Convert the polling client into an async stream of events.
    let client = Client::new()?;
    let mut stream = client.into_async();

    futures::executor::block_on(async {
        // High-level helper: wait for a specific condition without manual loops.
        let _ = stream
            .wait_for_predicate(|event, _| {
                matches!(event, Event::ConnectionLost | Event::ConnectFailed)
            })
            .await;

        // Stream-style iteration still works when you need full control.
        if let Some((event, _msg)) = stream.next().await
            && matches!(event, Event::ConnectionLost | Event::ConnectFailed)
        {
            // no-op
        }
    });

    // Graceful shutdown keeps lifecycle explicit in apps.
    stream.shutdown();
    let _client = stream.into_client();

    Ok(())
}

#[cfg(not(feature = "async"))]
fn main() {
    // This example requires the "async" feature.
    eprintln!("Enable the async feature: cargo run --example async_event_stream --features async");
}