diff --git a/src/stream.rs b/src/stream.rs index a83904f..52aba63 100644 --- a/src/stream.rs +++ b/src/stream.rs @@ -54,14 +54,12 @@ where pub async fn make_progress_with(&mut self, f: F) -> F::Output { let mut f = std::pin::pin!(f); - loop { - tokio::select! { - _ = self.make_progress() => { - return f.await; - } - output = &mut f => { - return output; - } + tokio::select! { + _ = self.make_progress() => { + return f.await; + } + output = &mut f => { + return output; } } }