Disable streaming

Currently seriously regressed and slow
circuithub · Jan 8, 2018 · 7650254 · 7650254
1 parent a7185ba
commit 7650254
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/Rel8/IO.hs b/Rel8/IO.hs
@@ -63,7 +63,8 @@ type QueryRunner m = forall a. Pg.RowParser a -> Pg.Query -> Stream (Of a) m ()
 -- 'stream' = 'queryWith_'
 -- @
 stream :: (MonadResource m) => Connection -> QueryRunner m
-stream conn parser query = queryWith_ parser conn query
+stream conn parser query =
+  liftIO (Pg.queryWith_ parser conn query) >>= S.each
 
 -- | Stream the results of a query and fetch the results using a PostgreSQL
 -- cursor. This variation is slightly more expensive, but has the benefit that