From 8df3db566a3a937b45ebf11adb90d265e6f5e2d4 Mon Sep 17 00:00:00 2001
From: Andreas Baumann <mail@andreasbaumann.cc>
Date: Sun, 17 Nov 2019 20:45:02 +0100
Subject: initial checking of customized version 1.0rc9

---
 .../guzzle/src/Guzzle/Batch/FlushingBatch.php      | 60 ++++++++++++++++++++++
 1 file changed, 60 insertions(+)
 create mode 100644 vendor/guzzle/guzzle/src/Guzzle/Batch/FlushingBatch.php

(limited to 'vendor/guzzle/guzzle/src/Guzzle/Batch/FlushingBatch.php')

diff --git a/vendor/guzzle/guzzle/src/Guzzle/Batch/FlushingBatch.php b/vendor/guzzle/guzzle/src/Guzzle/Batch/FlushingBatch.php
new file mode 100644
index 0000000..367b684
--- /dev/null
+++ b/vendor/guzzle/guzzle/src/Guzzle/Batch/FlushingBatch.php
@@ -0,0 +1,60 @@
+<?php
+
+namespace Guzzle\Batch;
+
+/**
+ * BatchInterface decorator used to add automatic flushing of the queue when the size of the queue reaches a threshold.
+ */
+class FlushingBatch extends AbstractBatchDecorator
+{
+    /** @var int The threshold for which to automatically flush */
+    protected $threshold;
+
+    /** @var int Current number of items known to be in the queue */
+    protected $currentTotal = 0;
+
+    /**
+     * @param BatchInterface $decoratedBatch  BatchInterface that is being decorated
+     * @param int            $threshold       Flush when the number in queue matches the threshold
+     */
+    public function __construct(BatchInterface $decoratedBatch, $threshold)
+    {
+        $this->threshold = $threshold;
+        parent::__construct($decoratedBatch);
+    }
+
+    /**
+     * Set the auto-flush threshold
+     *
+     * @param int $threshold The auto-flush threshold
+     *
+     * @return FlushingBatch
+     */
+    public function setThreshold($threshold)
+    {
+        $this->threshold = $threshold;
+
+        return $this;
+    }
+
+    /**
+     * Get the auto-flush threshold
+     *
+     * @return int
+     */
+    public function getThreshold()
+    {
+        return $this->threshold;
+    }
+
+    public function add($item)
+    {
+        $this->decoratedBatch->add($item);
+        if (++$this->currentTotal >= $this->threshold) {
+            $this->currentTotal = 0;
+            $this->decoratedBatch->flush();
+        }
+
+        return $this;
+    }
+}
-- 
cgit v1.2.3-54-g00ecf