#opc #tokio #codec #pixel #open-pixel-control

tk-opc

Minimal copy implementation for OpenPixelControl with tokio encoder/decoder

4 releases

Uses old Rust 2015

0.1.3 Apr 23, 2017
0.1.2 Apr 22, 2017
0.1.1 Apr 22, 2017
0.1.0 Apr 22, 2017

#10 in #opc

21 downloads per month

MIT license

12KB
349 lines

Minimal copy (only copies are to/from the tokio encode/decoder buffer object) open pixel control rust library.

Example OPC server:

    let mut core = Core::new().unwrap();
    let handle = core.handle();

    let addr = "127.0.0.1:12345".parse().unwrap();
    let listener = TcpListener::bind(&addr, &handle).unwrap();

    // send the message from the server to another thread...
    let (send, recv) = futures::sync::mpsc::channel(0);

    let server = listener.incoming().for_each(|(stream, _)| {
        let (_, stream) = stream.framed(opc::OPCCodec).split();
        // using this and not 'handle.spawn(...);Ok(())' should guarantee one connection at at time.
        send.clone().sink_map_err(|_| ()).send_all(stream.map_err(|_| ())).then(|_|Ok(()))
    });

Dependencies

~610KB
~11K SLoC