Add buffer size parameter

amphp · Aug 3, 2024 · 25c7662 · 25c7662
1 parent 0e940e6
commit 25c7662
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/functions.php b/src/functions.php
@@ -40,12 +40,13 @@ function synchronized(Semaphore $semaphore, \Closure $synchronized, mixed ...$ar
 }
 
 /**
+ * @param int $bufferSize Number of channel items to buffer in memory before back-pressure is applied.
  * @return array{Channel, Channel}
  */
-function createChannelPair(): array
+function createChannelPair(int $bufferSize = 0): array
 {
-    $west = new Queue();
-    $east = new Queue();
+    $west = new Queue($bufferSize);
+    $east = new Queue($bufferSize);
 
     return [
         new ConcurrentIteratorChannel($west->iterate(), $east),