39 lines
1.5 KiB
Rust
39 lines
1.5 KiB
Rust
use s2n_quic::Server;
|
|
use std::error::Error;
|
|
|
|
/// NOTE: this certificate is to be used for demonstration purposes only!
|
|
pub static CERT_PEM: &str = include_str!("../../cert.pem");
|
|
/// NOTE: this certificate is to be used for demonstration purposes only!
|
|
pub static KEY_PEM: &str = include_str!("../../key.pem");
|
|
|
|
#[tokio::main]
|
|
async fn main() -> Result<(), Box<dyn Error>> {
|
|
let mut server = Server::builder()
|
|
.with_tls((CERT_PEM, KEY_PEM))?
|
|
.with_io("127.0.0.1:4433")?
|
|
.start()?;
|
|
|
|
while let Some(mut connection) = server.accept().await {
|
|
// spawn a new task for the connection
|
|
tokio::spawn(async move {
|
|
eprintln!("Connection accepted from {:?}", connection.remote_addr());
|
|
|
|
while let Ok(Some(mut stream)) = connection.accept_bidirectional_stream().await {
|
|
// spawn a new task for the stream
|
|
tokio::spawn(async move {
|
|
eprintln!("Stream opened from {:?}", stream.connection().remote_addr());
|
|
|
|
// echo any data back to the stream
|
|
while let Ok(Some(data)) = stream.receive().await {
|
|
stream.send(data).await.expect("stream should be open");
|
|
}
|
|
|
|
println!("Stream closed from {:?}", stream.connection().remote_addr());
|
|
});
|
|
}
|
|
println!("Connection closed from {:?}", connection.remote_addr());
|
|
});
|
|
}
|
|
|
|
Ok(())
|
|
} |