Actually remove backpressure

amphp · Mar 30, 2018 · 2340e03 · 2340e03
1 parent d91f805
commit 2340e03
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/PqUnbufferedResultSet.php b/src/PqUnbufferedResultSet.php
@@ -34,7 +34,7 @@ public function __construct(callable $fetch, pq\Result $result) {
             try {
                 do {
                     $result->autoConvert = pq\Result::CONV_SCALAR | pq\Result::CONV_ARRAY;
-                    yield $emit($result);
+                    $emit($result);
                     $result = yield $fetch();
                 } while ($result instanceof pq\Result);
             } finally {