From 21717b47a07797d849c556cc7ee93fea5b599c87 Mon Sep 17 00:00:00 2001
From: Ryan Leckey <ryan@launchbadge.com>
Date: Thu, 18 Jun 2020 18:59:23 -0700
Subject: [PATCH] fix: AsyncStream should use a zero-capacity stream to ensure
 we run in lock-step

---
 sqlx-core/src/ext/async_stream.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sqlx-core/src/ext/async_stream.rs b/sqlx-core/src/ext/async_stream.rs
index 9afec69f..af368c7b 100644
--- a/sqlx-core/src/ext/async_stream.rs
+++ b/sqlx-core/src/ext/async_stream.rs
@@ -21,7 +21,7 @@ impl<'a, T> TryAsyncStream<'a, T> {
         Fut: 'a + Future<Output = Result<(), Error>> + Send,
         T: 'a + Send,
     {
-        let (mut sender, receiver) = mpsc::channel(1);
+        let (mut sender, receiver) = mpsc::channel(0);
 
         let future = f(sender.clone());
         let future = async move {