diff --git a/neqo-bin/src/client/mod.rs b/neqo-bin/src/client/mod.rs index ec6a9dc40c..02e051c236 100644 --- a/neqo-bin/src/client/mod.rs +++ b/neqo-bin/src/client/mod.rs @@ -417,7 +417,7 @@ impl<'a, H: Handler> Runner<'a, H> { } match ready(self.socket, self.timeout.as_mut()).await? { - Ready::Socket => self.process_multiple_input().await?, + Ready::Socket => self.process_multiple_input()?, Ready::Timeout => { self.timeout = None; } @@ -447,7 +447,7 @@ impl<'a, H: Handler> Runner<'a, H> { Ok(()) } - async fn process_multiple_input(&mut self) -> Res<()> { + fn process_multiple_input(&mut self) -> Res<()> { loop { let dgrams = self.socket.recv(&self.local_addr)?; if dgrams.is_empty() { @@ -455,8 +455,6 @@ impl<'a, H: Handler> Runner<'a, H> { } self.client .process_multiple_input(dgrams.iter(), Instant::now()); - self.process_output().await?; - self.handler.maybe_key_update(&mut self.client)?; } Ok(())