flo_scene_pipe 0.2.0

Inter-scene and inter-process communication for flo_scene
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

use flo_scene::*;
use flo_scene_pipe::*;
use flo_scene_pipe::commands::*;

use tokio;

use std::fs;

#[tokio::main]
async fn main() {
    // Delete the './example_unix_socket' file if it exists
    fs::remove_file("./example_unix_socket").ok();

    // Create a default scene
    let scene = Scene::default()
        .with_standard_json_commands();

    // Create a unix socket that will run commands
    let command_program = SubProgramId::new();
    scene.add_subprogram(command_program, |input, context| command_connection_program(input, context, ()), 0);

    // Set up a UNIX socket that can be used to stream commands to this program
    let socket_program = SubProgramId::new();
    start_unix_socket_program(&scene, socket_program, "./example_unix_socket", read_command_data, write_command_data).unwrap();

    // Connect the programs together
    scene.connect_programs(socket_program, command_program, StreamId::with_message_type::<CommandProgramSocketMessage>()).unwrap();

    // Run the scene
    println!("Created UNIX-domain socket at 'example_unix_socket'.\nTry 'socat - UNIX-CONNECT:./example_unix_socket' to connect.");
    println!();
    scene.run_scene().await;
}