tokio-jsoncodec 0.1.0

Integration between tokio-codec and serde_json
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

//! A simple JSON-based echo server over TCP using tokio-jsoncodec.

extern crate serde_json;
extern crate tokio;
extern crate tokio_codec;
extern crate tokio_jsoncodec;

use tokio::net::TcpListener;
use tokio::prelude::*;
use tokio_codec::Decoder;
use tokio_jsoncodec::Codec;

fn main() -> ! {
    let listen_addr = "[::]:7777".parse().unwrap();
    let listener = TcpListener::bind(&listen_addr).unwrap();
    eprintln!("Listening on {}", listen_addr);

    tokio::run(
        listener
            .incoming()
            .for_each(|tcp_stream| {
                let (sink, stream) = Codec::default().framed(tcp_stream).split();
                tokio::spawn(
                    sink.send_all(stream.map(|data: serde_json::Value| data))
                        .map(|_| ())
                        .map_err(|e| eprintln!("error in server: {:?}", e)),
                );
                Ok(())
            })
            .map_err(|e| eprintln!("error in server: {:?}", e)),
    );
    panic!("unexpectedly exited");
}