multiio 0.2.3

A unified I/O orchestration library for CLI/server applications
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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

//! Basic asynchronous example demonstrating multiio usage.
//!
//! Run with: cargo run --example basic_async --features async

#[cfg(feature = "async")]
mod async_example {
    use multiio::{ErrorPolicy, MultiioAsyncBuilder, default_async_registry};
    use serde::{Deserialize, Serialize};

    #[derive(Debug, Deserialize, Serialize)]
    struct Config {
        name: String,
        value: i32,
        enabled: bool,
    }

    pub async fn run() -> Result<(), Box<dyn std::error::Error>> {
        // Create a default async format registry
        let registry = default_async_registry();

        // Build an async I/O engine
        let engine = MultiioAsyncBuilder::new(registry)
            .add_input("examples/data/config.json")
            .add_output("-") // stdout
            .with_mode(ErrorPolicy::FastFail)
            .build()?;

        // Read all inputs asynchronously
        let configs: Vec<Config> = engine.read_all().await?;

        println!("Read {} config(s):", configs.len());
        for config in &configs {
            println!(
                "  - {}: {} (enabled: {})",
                config.name, config.value, config.enabled
            );
        }

        // Write all configs to outputs
        engine.write_all(&configs).await?;

        Ok(())
    }
}

#[cfg(feature = "async")]
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    async_example::run().await
}

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