From 80eb2cc7d23b3d470eb8229cd47e0f9eede9e20a Mon Sep 17 00:00:00 2001
From: Austin Bonander <austin.bonander@gmail.com>
Date: Fri, 10 Apr 2020 23:19:15 -0700
Subject: [PATCH] make the stream returned from `Map::fetch()` `Unpin`

closes #244
---
 sqlx-core/src/query.rs | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/sqlx-core/src/query.rs b/sqlx-core/src/query.rs
index 09f05f39..141da710 100644
--- a/sqlx-core/src/query.rs
+++ b/sqlx-core/src/query.rs
@@ -146,20 +146,20 @@ where
     pub fn fetch<'e: 'q, E>(
         mut self,
         executor: E,
-    ) -> impl Stream<Item = crate::Result<F::Output>> + 'e
+    ) -> impl Stream<Item = crate::Result<F::Output>> + Unpin + 'e
     where
         'q: 'e,
         E: RefExecutor<'e, Database = DB> + 'e,
         F: 'e,
         F::Output: 'e,
     {
-        try_stream! {
+        Box::pin(try_stream! {
             let mut cursor = executor.fetch_by_ref(self.query);
             while let Some(next) = cursor.next().await? {
                 let mapped = self.mapper.try_map_row(next)?;
                 yield mapped;
             }
-        }
+        })
     }
 
     /// Get the first row in the result