Skip to content

Commit

Permalink
fix(rust-quic): temporarily leak I/O task
Browse files Browse the repository at this point in the history
Signed-off-by: Roman Volosatovs <rvolosatovs@riseup.net>
  • Loading branch information
rvolosatovs committed Jul 3, 2024
1 parent e1d873a commit 58839bd
Showing 1 changed file with 6 additions and 4 deletions.
10 changes: 6 additions & 4 deletions crates/transport-quic/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -700,8 +700,9 @@ impl wrpc_transport::Invoke for Client {
.await
.context("failed to open parameter stream")?;
let index = Arc::new(std::sync::Mutex::new(paths.as_ref().iter().collect()));
let mut io = JoinSet::new();
io.spawn(demux_connection(Arc::clone(&index), conn.clone()).in_current_span());
let io = JoinSet::new();
// TODO: Use `io`
tokio::spawn(demux_connection(Arc::clone(&index), conn.clone()).in_current_span());
let io = Arc::new(io);
trace!("writing parameters");
param_tx
Expand Down Expand Up @@ -743,8 +744,9 @@ async fn serve_connection(
.context("failed to read parameter stream header")?;
ensure!(x == PROTOCOL);
let index = Arc::new(std::sync::Mutex::new(paths.iter().collect()));
let mut io = JoinSet::new();
io.spawn(demux_connection(Arc::clone(&index), conn.clone()).in_current_span());
let io = JoinSet::new();
// TODO: Use `io`
tokio::spawn(demux_connection(Arc::clone(&index), conn.clone()).in_current_span());
let io = Arc::new(io);
Ok((
Outgoing::Active {
Expand Down

0 comments on commit 58839bd

Please sign in to comment.