public function create($pipelineType, $pipelineParams)
    {
        if (!isset($this->factories[$pipelineType])) {
            throw new \LogicException("No factory found for pipeline aggregation of type {$pipelineType}");
        }

        return $this->factories[$pipelineType]->create($pipelineParams);
    }
public function create($pipelineType, $pipelineParams)
    {
        if (!isset($this->factories[$pipelineType])) {
            throw new \LogicException("No factory found for pipeline aggregation of type {$pipelineType}");
        }

        return $this->factories[$pipelineType]->create($pipelineParams);
    }
public function create ( $ pipelineType , $ pipelineParams ) { if ( ! isset ( $ this -> factories [ $ pipelineType ] ) ) { throw new \ LogicException ( "No factory found for pipeline aggregation of type {$pipelineType}" ) ; } return $ this -> factories [ $ pipelineType ] -> create ( $ pipelineParams ) ; }
Create a new pipeline from its type and params.

@param string $pipelineType   Pipeline type (must be a valid pipeline type defined into the factories array).
@param array  $pipelineParams Pipeline constructor params.

@return PipelineInterface
Create a new pipeline from its type and params .