From 0fcf265c41106b7eacfea18287d84a0e4b1b07a1 Mon Sep 17 00:00:00 2001 From: Aaron Piotrowski Date: Wed, 3 Apr 2019 10:22:32 -0500 Subject: [PATCH] Add missed reference --- src/PqUnbufferedResultSet.php | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/PqUnbufferedResultSet.php b/src/PqUnbufferedResultSet.php index be205d9..0742ef0 100644 --- a/src/PqUnbufferedResultSet.php +++ b/src/PqUnbufferedResultSet.php @@ -29,6 +29,8 @@ final class PqUnbufferedResultSet implements ResultSet { $this->numCols = $result->numCols; + $destroyed = &$this->destroyed; + $this->producer = new Producer(static function (callable $emit) use (&$destroyed, $release, $result, $fetch) { try { do {