Add connection count assertion

amphp · Mar 4, 2020 · aed9d14 · aed9d14
1 parent 485d44b
commit aed9d14
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/Connection/ConnectionLimitingPool.php b/src/Connection/ConnectionLimitingPool.php
@@ -177,6 +177,12 @@ private function getStreamFor(string $uri, Request $request, CancellationToken $
 
                 if ($stream === null) {
                     $connectionId = \spl_object_id($connection);
+
+                    \assert(
+                        !isset($this->activeRequestCounts[$connectionId])
+                        || $this->activeRequestCounts[$connectionId] >= 0
+                    );
+
                     if (!$this->isAdditionalConnectionAllowed($uri)
                         && ($this->activeRequestCounts[$connectionId] ?? 0) === 0
                     ) {