diff --git a/prototypes/quic_demo/src/bin/quic_demo_relay_server.rs b/prototypes/quic_demo/src/bin/quic_demo_relay_server.rs index 064c928..948eda9 100644 --- a/prototypes/quic_demo/src/bin/quic_demo_relay_server.rs +++ b/prototypes/quic_demo/src/bin/quic_demo_relay_server.rs @@ -199,8 +199,8 @@ struct RequestP2ToP4 { client_id: String, } -struct PtthNewConnection { - client_send: quinn::SendStream, +struct PtthNewConnection { + client_send: ClientSend, client_recv: quinn::RecvStream, server_send: quinn::SendStream, server_recv: quinn::RecvStream, @@ -211,7 +211,7 @@ struct PtthConnection { downlink_task: JoinHandle >, } -impl PtthNewConnection { +impl PtthNewConnection { fn build (self) -> PtthConnection { let Self { mut client_send, diff --git a/prototypes/quic_demo/src/prelude.rs b/prototypes/quic_demo/src/prelude.rs index 03fc349..b94e1d6 100644 --- a/prototypes/quic_demo/src/prelude.rs +++ b/prototypes/quic_demo/src/prelude.rs @@ -18,7 +18,9 @@ pub use anyhow::{ pub use futures_util::StreamExt; pub use tokio::{ io::{ + AsyncRead, AsyncReadExt, + AsyncWrite, AsyncWriteExt, }, net::TcpListener,