diff --git a/sqlx-core/src/ext/async_stream.rs b/sqlx-core/src/ext/async_stream.rs
index 75c5c8658..9616174fc 100644
--- a/sqlx-core/src/ext/async_stream.rs
+++ b/sqlx-core/src/ext/async_stream.rs
@@ -26,7 +26,7 @@ impl<'a, T> TryAsyncStream<'a, T> {
         let future = f(sender.clone());
         let future = async move {
             if let Err(error) = future.await {
-                let _ = sender.send(Err(error));
+                let _ = sender.send(Err(error)).await;
             }
 
             Ok(())
@@ -67,7 +67,7 @@ macro_rules! try_stream2 {
                 }
             }
 
-            {$($block)*}
+            $($block)*
         })
     }
 }