Lines 100.00% 2 / 2
Functions and Methods 100.00% 2 / 2
Classes and Traits 100.00% 1 / 1
Name Lines Functions and Methods CRAP Classes and Traits
OperatorStream 100.00% 2 / 2 100.00% 2 / 2 2 100.00% 1 / 1
 extendWith 100.00% 1 / 1 100.00% 1 / 1 1
 createPartitionKeyReader 100.00% 1 / 1 100.00% 1 / 1 1
1<?php
2
3declare(strict_types=1);
4
5namespace Stewart\Support\Stream;
6
7use Closure;
8
9/**
10 * @internal
11 * @template T
12 * @extends ComposedStream<T>
13 */
14final readonly class OperatorStream extends ComposedStream
15{
16    protected function extendWith(StreamSource $stage): static
17    {
18        return new static($stage, $this->timers);
19    }
20
21    protected function createPartitionKeyReader(): Closure
22    {
23        return static fn(mixed $event): string => '';
24    }
25}