Removing a deprecated class

php-etl · Sep 28, 2021 · e0d6af2 · e0d6af2
1 parent ea1e664
commit e0d6af2
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/Transformer/BatchingTransformer.php b/src/Transformer/BatchingTransformer.php
@@ -2,7 +2,7 @@
 
 namespace Kiboko\Component\Pipeline\Transformer;
 
-use Kiboko\Component\Bucket\AcceptanceAppendableResultBucket;
+use Kiboko\Component\Bucket\AppendableIteratorAcceptanceResultBucket;
 use Kiboko\Component\Bucket\EmptyResultBucket;
 use Kiboko\Contract\Bucket\ResultBucketInterface;
 use Kiboko\Contract\Pipeline\FlushableInterface;
@@ -18,10 +18,10 @@ public function __construct(private int $batchSize)
         $this->bucket = new EmptyResultBucket();
     }
 
-    /** @return \Generator<mixed, AcceptanceAppendableResultBucket<Type>|EmptyResultBucket, null|Type, void> */
+    /** @return \Generator<mixed, AppendableIteratorAcceptanceResultBucket<Type>|EmptyResultBucket, null|Type, void> */
     public function transform(): \Generator
     {
-        $this->bucket = new AcceptanceAppendableResultBucket();
+        $this->bucket = new AppendableIteratorAcceptanceResultBucket();
         $itemCount = 0;
 
         $line = yield new EmptyResultBucket();
@@ -31,7 +31,7 @@ public function transform(): \Generator
             if ($this->batchSize <= ++$itemCount) {
                 $line = yield $this->bucket;
                 $itemCount = 0;
-                $this->bucket = new AcceptanceAppendableResultBucket();
+                $this->bucket = new AppendableIteratorAcceptanceResultBucket();
             } else {
                 $line = yield new EmptyResultBucket();
             }