6 releases

0.2.1 Dec 28, 2023
0.2.0 Dec 26, 2023
0.1.3 Sep 11, 2023

#65 in #ipc

MIT license

13KB
261 lines

ilgda-ipc

IPC standard used for ilgda

temp readme will fix soon™

Example

use tokio::join;
use ilgda_ipc::async_channels::{AsyncIpcReceiver, AsyncIpcSender};

#[tokio::main]
async fn main() {
let (tx, rx) = ipc_channel::ipc::channel().unwrap();

    let mut tx = AsyncIpcSender::new(tx);
    let mut rx = AsyncIpcReceiver::new(rx);

    join!(
        async { tx.send(u128::MAX).await.expect("failed to send data") },
        async { assert_eq!(u128::MAX, rx.recv().await.expect("failed to receive")) }
    );
}

Dependencies

~5–33MB
~527K SLoC