lightstream 0.4.4

Composable, zero-copy Arrow IPC and native data streaming for Rust with SIMD-aligned I/O, async support, and memory-mapping.
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

//! Unix Domain Socket Transport Example
//!
//! Demonstrates the Lightstream protocol over Unix domain sockets.
//! Uses a temporary directory for the socket path.
//!
//! Run with:
//! ```sh
//! cargo run --example uds_lightstream --features "protocol,uds,msgpack"
//! ```

#[path = "../helpers/mod.rs"]
mod helpers;

use helpers::{recv_and_print_all, register_demo_types, send_demo_messages};
use lightstream::models::protocol::connection::UdsLightstreamConnection;
use tokio::net::UnixListener;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("Unix Domain Socket Transport Example");
    println!("=====================================\n");

    let temp_dir = tempfile::tempdir()?;
    let socket_path = temp_dir.path().join("lightstream.sock");
    println!("Socket path: {}", socket_path.display());

    let listener = UnixListener::bind(&socket_path)?;
    println!("Listener bound.");

    let path_clone = socket_path.clone();
    let server = tokio::spawn(async move {
        let (stream, _) = listener.accept().await.unwrap();
        println!("Server accepted connection.");

        let mut conn = UdsLightstreamConnection::from_uds(stream);
        register_demo_types(&mut conn);
        recv_and_print_all(&mut conn).await;
        println!("Server connection closed.");
    });

    let client_stream = tokio::net::UnixStream::connect(&path_clone).await?;
    println!("Client connected.");

    let mut client = UdsLightstreamConnection::from_uds(client_stream);
    register_demo_types(&mut client);
    send_demo_messages(&mut client, "uds").await?;

    server.await?;
    println!("\nUDS transport example completed successfully!");
    Ok(())
}