don't sync after PortalSuspended

Author: tpolecat

modules/core/shared/src/main/scala/net/protocol/Unroll.scala

@@ -77,7 +77,7 @@ private[protocol] class Unroll[F[_]: MessageSocket: Trace](
       flatExpect {
         case rd @ RowData(_)          => accumulate(rd.fields :: accum)
         case      CommandComplete(_)  => sync.as((accum.reverse ~ false))
-        case      PortalSuspended     => sync.as((accum.reverse ~ true))
+        case      PortalSuspended     => (accum.reverse ~ true).pure[F]
         case      ErrorResponse(info) => syncAndFail(info)
       }
 

modules/tests/shared/src/test/scala/issue/628.scala

@@ -0,0 +1,21 @@
+// Copyright (c) 2018-2021 by Rob Norris
+// This software is licensed under the MIT License (MIT).
+// For more information see LICENSE or https://opensource.org/licenses/MIT
+
+package tests.issue
+
+import skunk._
+import skunk.codec.all._
+import skunk.implicits._
+import tests.SkunkTest
+
+// https://github.com/tpolecat/skunk/issues/628
+class Test628 extends SkunkTest {
+
+  sessionTest("issue/628") { s =>
+    s.prepare(sql"select name from country".query(varchar)).use { ps =>
+      ps.stream(Void, 10).compile.toList
+    }
+  }
+
+}