Reset continuous reads in defer

amphp · Dec 31, 2022 · b5a09a3 · b5a09a3
1 parent 9bb5564
commit b5a09a3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/ReadableResourceStream.php b/src/ReadableResourceStream.php
@@ -223,7 +223,7 @@ public function read(?Cancellation $cancellation = null, ?int $limit = null): ?s
             EventLoop::defer($this->resumeSuspension);
             $this->suspension->suspend();
         } elseif ($this->continuousReads++ === 0) {
-            EventLoop::queue($this->resetContinuousReads);
+            EventLoop::defer($this->resetContinuousReads);
         }
 
         return $data;