PipelineSteps
Read onlyYes
FinalYes
Properties
Methods
- __construct() : mixed
- followedBy() : bool
- A step after $step, in this pipeline, that is an instance of one of $classes.
- from() : self
- What remains from $step on: the steps from it and the breaker. Nothing remains when $step is null.
- isEmpty() : bool
Properties
$breaker
public
JoinStep|Processor|null
$breaker
= null
$steps
public
array<string|int, mixed>
$steps
= []
Methods
__construct()
public
__construct([array<int, JoinStep|Loader|Processor|BranchPipeline|TransactionGroup|Transformer> $steps = [] ][, null|JoinStep|Processor $breaker = null ]) : mixed
Parameters
- $steps : array<int, JoinStep|Loader|Processor|BranchPipeline|TransactionGroup|Transformer> = []
-
in execution order; a processor or cross join among them streams
- $breaker : null|JoinStep|Processor = null
-
the step that needs every row before it emits, ending the pipeline
followedBy()
A step after $step, in this pipeline, that is an instance of one of $classes.
public
followedBy(object $step, class-string ...$classes) : bool
Parameters
- $step : object
- $classes : class-string
Return values
boolfrom()
What remains from $step on: the steps from it and the breaker. Nothing remains when $step is null.
public
from(JoinStep|Loader|Processor|BranchPipeline|TransactionGroup|Transformer|null $step) : self
Parameters
- $step : JoinStep|Loader|Processor|BranchPipeline|TransactionGroup|Transformer|null
Return values
selfisEmpty()
public
isEmpty() : bool