class EntityProcessingPipeline (View source)

Methods

addProcessor(EntityProcessor $processor)

Add a processor to the pipeline

removeProcessor(string $processorClass)

Remove a processor by class name

array
getProcessors()

Get all processors in the pipeline

clearProcessors()

Clear all processors from the pipeline

mixed|null
processSingle(mixed $entity, array $context = [])

Process a single entity through the pipeline

array
processBatch(array $entities)

Process multiple entities through the pipeline (batch processing)

Details

EntityProcessingPipeline addProcessor(EntityProcessor $processor)

Add a processor to the pipeline

Parameters

EntityProcessor $processor

Return Value

EntityProcessingPipeline

For fluent interface

EntityProcessingPipeline removeProcessor(string $processorClass)

Remove a processor by class name

Parameters

string $processorClass

Return Value

EntityProcessingPipeline

For fluent interface

array getProcessors()

Get all processors in the pipeline

Return Value

array

EntityProcessingPipeline clearProcessors()

Clear all processors from the pipeline

Return Value

EntityProcessingPipeline

For fluent interface

mixed|null processSingle(mixed $entity, array $context = [])

Process a single entity through the pipeline

Parameters

mixed $entity

The entity to process

array $context

Additional context for processors

Return Value

mixed|null

Processed entity, or null if filtered out

array processBatch(array $entities)

Process multiple entities through the pipeline (batch processing)

Parameters

array $entities

Return Value

array

Processed entities (filtered entities removed)