multi-rpc 0.3.1

Define a Rust service trait once and serve it simultaneously over multiple RPC protocols like Tarpc, REST/Axum, and JSON-RPC.
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

use std::io;

use tokio::task::JoinHandle;

/// Manages the spawned server tasks, waiting for a shutdown signal to terminate them.
pub struct ServerRunner {
    pub(crate) handles: Vec<JoinHandle<()>>,
}

impl ServerRunner {
    /// Runs all configured servers and blocks the current task until a shutdown
    /// signal (Ctrl+C) is received.
    ///
    /// Upon receiving the signal, it aborts all spawned server tasks.
    pub async fn run(self) -> io::Result<()> {
        println!("✅ Servers running. Press Ctrl+C to shut down.");
        tokio::signal::ctrl_c().await?;

        println!("\nShutdown signal received. Aborting server tasks...");
        for handle in self.handles {
            handle.abort();
        }

        Ok(())
    }
}