embedded_basic/
embedded-basic.rs

1use koi_embedded::{Builder, ServiceMode};
2use tokio_stream::StreamExt;
3
4#[tokio::main]
5async fn main() -> Result<(), Box<dyn std::error::Error>> {
6    let koi = Builder::new()
7        .service_mode(ServiceMode::EmbeddedOnly)
8        .build()?;
9    let handle = koi.start().await?;
10
11    let mut events = handle.events();
12    tokio::spawn(async move {
13        while let Some(Ok(event)) = events.next().await {
14            println!("event: {event:?}");
15        }
16    });
17
18    Ok(())
19}

embedded_basic/embedded-basic.rs

embedded_basic/
embedded-basic.rs