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 futures::prelude::*;
use serde_json::Value;
use tokio::net::TcpListener;
use tokio_serde::formats::*;
use tokio_util::codec::{FramedRead, LengthDelimitedCodec};
#[tokio::main]
pub async fn main() {
// Bind a server socket
let listener = TcpListener::bind("127.0.0.1:17653").await.unwrap();
println!("listening on {:?}", listener.local_addr());
loop {
let (socket, _) = listener.accept().await.unwrap();
// Delimit frames using a length header
let length_delimited = FramedRead::new(socket, LengthDelimitedCodec::new());
// Deserialize frames
let mut deserialized = tokio_serde::SymmetricallyFramed::new(
length_delimited,
SymmetricalJson::<Value>::default(),
);
// Spawn a task that prints all received messages to STDOUT
tokio::spawn(async move {
while let Some(msg) = deserialized.try_next().await.unwrap() {
println!("GOT: {:?}", msg);
}
});
}
}
|
