Skip to content

Commit e0d6af2

Browse files
committed
Removing a deprecated class
1 parent ea1e664 commit e0d6af2

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/Transformer/BatchingTransformer.php

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
namespace Kiboko\Component\Pipeline\Transformer;
44

5-
use Kiboko\Component\Bucket\AcceptanceAppendableResultBucket;
5+
use Kiboko\Component\Bucket\AppendableIteratorAcceptanceResultBucket;
66
use Kiboko\Component\Bucket\EmptyResultBucket;
77
use Kiboko\Contract\Bucket\ResultBucketInterface;
88
use Kiboko\Contract\Pipeline\FlushableInterface;
@@ -18,10 +18,10 @@ public function __construct(private int $batchSize)
1818
$this->bucket = new EmptyResultBucket();
1919
}
2020

21-
/** @return \Generator<mixed, AcceptanceAppendableResultBucket<Type>|EmptyResultBucket, null|Type, void> */
21+
/** @return \Generator<mixed, AppendableIteratorAcceptanceResultBucket<Type>|EmptyResultBucket, null|Type, void> */
2222
public function transform(): \Generator
2323
{
24-
$this->bucket = new AcceptanceAppendableResultBucket();
24+
$this->bucket = new AppendableIteratorAcceptanceResultBucket();
2525
$itemCount = 0;
2626

2727
$line = yield new EmptyResultBucket();
@@ -31,7 +31,7 @@ public function transform(): \Generator
3131
if ($this->batchSize <= ++$itemCount) {
3232
$line = yield $this->bucket;
3333
$itemCount = 0;
34-
$this->bucket = new AcceptanceAppendableResultBucket();
34+
$this->bucket = new AppendableIteratorAcceptanceResultBucket();
3535
} else {
3636
$line = yield new EmptyResultBucket();
3737
}

0 commit comments

Comments
 (0)