src/Pipeline/AbstractProcessor.php
protected function processPipeClassName(string $pipe, $payload)
    {
        if (isset($this->container)) {
            $pinst = $this->container->get($pipe);
        }

        if (!isset($pinst)) {
            $pinst = new $pipe();
        }

        if (!$pinst instanceof PipeInterface) {
            throw new MissingPipeInterfaceException(get_class($pinst));
        }

        return $pinst($payload);
    }
protected function processPipeClassName(string $pipe, $payload)
    {
        if (isset($this->container)) {
            $pinst = $this->container->get($pipe);
        }

        if (!isset($pinst)) {
            $pinst = new $pipe();
        }

        if (!$pinst instanceof PipeInterface) {
            throw new MissingPipeInterfaceException(get_class($pinst));
        }

        return $pinst($payload);
    }
protected function processPipeClassName ( string $ pipe , $ payload ) { if ( isset ( $ this -> container ) ) { $ pinst = $ this -> container -> get ( $ pipe ) ; } if ( ! isset ( $ pinst ) ) { $ pinst = new $ pipe ( ) ; } if ( ! $ pinst instanceof PipeInterface ) { throw new MissingPipeInterfaceException ( get_class ( $ pinst ) ) ; } return $ pinst ( $ payload ) ; }
Process Pipe string class name

@param string $pipe
@param mixed $payload
@return mixed
@throws MissingPipeInterfaceException
Process Pipe string class name