prototypes/quic_demo/src/bin/quic_demo_relay_server.rs

@@ -29,9 +29,7 @@ async fn main () -> anyhow::Result <()> {
 	let listen_addr = opt.listen_addr.unwrap_or_else (|| String::from ("0.0.0.0:30380")).parse ()?;
 	let (mut incoming, server_cert) = make_server_endpoint (listen_addr)?;
 	println! ("Base64 cert: {}", base64::encode (&server_cert));
-	
-	tokio::fs::create_dir_all ("ptth_quic_output").await?;
-	tokio::fs::write ("ptth_quic_output/quic_server.crt", &server_cert).await?;
+	tokio::fs::write ("quic_server.crt", &server_cert).await?;
 	
 	let relay_state = Arc::new (RelayState::default ());
 	
@@ -201,8 +199,8 @@ struct RequestP2ToP4 {
 	client_id: String,
 }
 
-struct PtthNewConnection {
-	client_send: quinn::SendStream,
+struct PtthNewConnection <ClientSend: AsyncWrite + Unpin> {
+	client_send: ClientSend,
 	client_recv: quinn::RecvStream,
 	server_send: quinn::SendStream,
 	server_recv: quinn::RecvStream,
@@ -213,7 +211,7 @@ struct PtthConnection {
 	downlink_task: JoinHandle <anyhow::Result <()>>,
 }
 
-impl PtthNewConnection {
+impl <ClientSend: AsyncWrite + Unpin> PtthNewConnection <ClientSend> {
 	fn build (self) -> PtthConnection {
 		let Self {
 			mut client_send,

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,