Crate tokio_quicker
source ·Expand description
Async QUIC Listener/Socket for tokio using quiche.
§Examples
§Client
First create a QuicSocket
.
ⓘ
let mut connection = QuicSocket::bind("127.0.0.1:0")
.await?
.connect(Some("localhost"), "127.0.0.1:4433")
.await?;
Then you can start opening new QuicStream
s or receive incoming ones from the server.
ⓘ
let mut stream = connection.bidi(1).await?;
ⓘ
let mut stream = connection.incoming().await?;
These implement the tokio AsyncRead
and AsyncWrite
traits.
§Server
Again create a QuicListener
.
ⓘ
let mut listener = QuicListener::bind("127.0.0.1:4433").await?;
Then you can use a while loop to accept incoming connection and either handle them directly on the thread or move them to a new one.
ⓘ
while let Ok(mut connection) = listener.accept().await {
tokio::spawn(async move {
let mut stream = connection.incoming().await?;
...
stream.shutdown().await?;
});
}
Modules§
Structs§
QuicListener
is used to bind to a specified address/port.QuicSocket
opens a connection from a specified address/port to a server.