reactor
/
ptth
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Revert "🚧 wip" 

This reverts commit 05ba4822f8.
main
_ 2021-10-01 10:41:44 -05:00
parent 05ba4822f8
commit 7408d41d47
2 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
prototypes/quic_demo/src/bin/quic_demo_relay_server.rs
View File

@ -199,8 +199,8 @@ struct RequestP2ToP4 {
client_id: String, client_id: String,
} }
struct PtthNewConnection <ClientSend: AsyncWrite + Unpin> { struct PtthNewConnection {
client_send: ClientSend, client_send: quinn::SendStream,
client_recv: quinn::RecvStream, client_recv: quinn::RecvStream,
server_send: quinn::SendStream, server_send: quinn::SendStream,
server_recv: quinn::RecvStream, server_recv: quinn::RecvStream,
@ -211,7 +211,7 @@ struct PtthConnection {
downlink_task: JoinHandle <anyhow::Result <()>>, downlink_task: JoinHandle <anyhow::Result <()>>,
} }
impl <ClientSend: AsyncWrite + Unpin> PtthNewConnection <ClientSend> { impl PtthNewConnection {
fn build (self) -> PtthConnection { fn build (self) -> PtthConnection {
let Self { let Self {
mut client_send, mut client_send,

2
prototypes/quic_demo/src/prelude.rs
View File

@ -18,9 +18,7 @@ pub use anyhow::{
pub use futures_util::StreamExt; pub use futures_util::StreamExt;
pub use tokio::{ pub use tokio::{
io::{ io::{
AsyncRead,
AsyncReadExt, AsyncReadExt,
AsyncWrite,
AsyncWriteExt, AsyncWriteExt,
}, },
net::TcpListener, net::TcpListener,