RunCounts
FinalYes
Methods
- __construct() : mixed
- absorb() : void
- Takes over every read $other counted, as if this one had counted it; a source new to this one keeps what it declared when $other opened it.
- absorbWorkers() : void
- Takes over the worker peaks $other saw and none of its reads: an abandoned attempt's workers used that memory, while its source is read again.
- count() : Generator<null|Signal, void>
- Passes $batches through unchanged. A stop is forwarded and ends the count: the consumer that sent it reads no further batch, so that read never closes.
- open() : SourceCount
- The opened read of $extractor, created on first use: whoever drives the source counts into it and closes it.
- processes() : Processes
- statistics() : array<int, SourceStatistics>
- worker() : void
Methods
__construct()
public
__construct() : mixed
absorb()
Takes over every read $other counted, as if this one had counted it; a source new to this one keeps what it declared when $other opened it.
public
absorb(self $other) : void
Parameters
- $other : self
absorbWorkers()
Takes over the worker peaks $other saw and none of its reads: an abandoned attempt's workers used that memory, while its source is read again.
public
absorbWorkers(self $other) : void
Parameters
- $other : self
count()
Passes $batches through unchanged. A stop is forwarded and ends the count: the consumer that sent it reads no further batch, so that read never closes.
public
count(Extractor $extractor, Generator<string|int, T> $batches, bool $narrowed) : Generator<null|Signal, void>
Parameters
- $extractor : Extractor
- $batches : Generator<string|int, T>
-
what $extractor yields
- $narrowed : bool
-
a limit or a partition filter was pushed into this read
Tags
Return values
Generator<null|Signal, void>open()
The opened read of $extractor, created on first use: whoever drives the source counts into it and closes it.
public
open(Extractor $extractor, bool $narrowed) : SourceCount
Parameters
- $extractor : Extractor
- $narrowed : bool
-
a limit or a partition filter was pushed into this read
Return values
SourceCountprocesses()
public
processes(Unit $parent) : Processes
Parameters
- $parent : Unit
Return values
Processesstatistics()
public
statistics() : array<int, SourceStatistics>
Return values
array<int, SourceStatistics> —in the order the sources were first read
worker()
public
worker(int $pid, int $peakBytes) : void
Parameters
- $pid : int
- $peakBytes : int