diff --git a/examples/src/routeguide/client.rs b/examples/src/routeguide/client.rs index efa7a86..02989be 100644 --- a/examples/src/routeguide/client.rs +++ b/examples/src/routeguide/client.rs @@ -65,7 +65,8 @@ async fn run_route_chat(client: &mut RouteGuideClient) -> Result<(), Bo let outbound = async_stream::stream! { let mut interval = time::interval(Duration::from_secs(1)); - while let time = interval.tick().await { + loop { + let time = interval.tick().await; let elapsed = time.duration_since(start); let note = RouteNote { location: Some(Point { diff --git a/examples/src/uds/server.rs b/examples/src/uds/server.rs index fb26bcd..8ffe4fa 100644 --- a/examples/src/uds/server.rs +++ b/examples/src/uds/server.rs @@ -50,7 +50,9 @@ async fn main() -> Result<(), Box> { let uds = UnixListener::bind(path)?; async_stream::stream! { - while let item = uds.accept().map_ok(|(st, _)| unix::UnixStream(st)).await { + loop { + let item = uds.accept().map_ok(|(st, _)| unix::UnixStream(st)).await; + yield item; } }