sequoia-ipc 0.36.1

Interprocess communication infrastructure for Sequoia
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 crate::hello_protocol_capnp::hello;
use anyhow::Result;
use capnp_rpc::rpc_twoparty_capnp::Side;
use sequoia_ipc as ipc;

pub fn run(desc: ipc::Descriptor) -> Result<()> {
    let client = async move {
        let mut rpc_system = desc.connect()?;
        let hello: hello::Client = rpc_system.bootstrap(Side::Server);

        tokio::task::spawn_local(rpc_system);

        let mut request = hello.hello_request();
        request.get().set_name("ipc-client");

        let response = request.send().promise.await?;

        println!("received: {}", response.get()?.get_response()?.to_str()?);

        Ok(())
    };

    let local = tokio::task::LocalSet::new();
    let runtime = tokio::runtime::Runtime::new()?;
    local.block_on(&runtime, client)
}