pipes

Tubos para PHP com uma API simples baseada em composição funcional

Simplificando, ele leva a saída do último e o transa para o próximo. Meio que Bash cat ./file | grep -e 'waldo'

Instalação

Você pode instalar o pacote via compositor:

composer require inmanturbo/pipes

Ou apenas copie ou faça o download do arquivo functions.php deste repositório.

Uso

cano()

 require __DIR__ . ' /../vendor/autoload.php ' ;

use function Inmanturbo  Pipes  pipe ;

$ addOne = fn ( $ number = 0 ) => $ number + 1 ;

$ five = pipe ( $ addOne ) // 1
    -> pipe ( fn ( $ number ) => $ number + 1 ) // 2
    -> pipe ( $ addOne ) // 3
    -> pipe ( $ addOne ) // 4
    -> thenReturn (); // 4

Não atrasa a execução

 $ fifty = pipe ( 1 );

    while ( $ fifty -> result () < 50 ) {
        $ fifty -> pipe ( fn ( $ number ) => ++ $ number );
    }

echo $ fifty -> result ();
// 50
     

Você também pode passar uma aula ou uma string de classe

 use function Inmanturbo  Pipes  pipe ;

class Subtract
{
    public function __invoke ( $ number )
    {
        return $ number - 1 ;
    }
}

$ addOne = fn ( $ number = 0 ) => $ number + 1 ;

$ six = pipe ( $ addOne , 1 )
    -> pipe ( $ addOne )
    -> pipe ( $ addOne )
    -> pipe ( $ addOne )
    -> then ( fn ( $ number ) => ++ $ number );

$ five = pipe ( $ six )
    -> pipe (Subtract::class)
    -> thenReturn ();

$ three = pipe ( new Subtract , $ five )
    -> pipe ( new Subtract )
    -> thenReturn ();

Resultados de retorno

Os resultados podem ser retornados de três maneiras:

then() ou thenReturn() um retorno de chamada final e retorne o resultado, ou result() , que simplesmente retorna o resultado.

 $ addOne = fn ( $ number = 0 ) => $ number + 1 ;

$ six = pipe ( $ addOne , 1 )
    -> pipe ( $ addOne )
    -> pipe ( $ addOne )
    -> pipe ( $ addOne )
    -> then ( fn ( $ number ) => ++ $ number );

$ sixAgain = pipe ( $ addOne , 1 )
    -> pipe ( $ addOne )
    -> pipe ( $ addOne )
    -> pipe ( $ addOne )
    -> thenReturn ( fn ( $ number ) => ++ $ number );

$ five = pipe ( $ addOne , 1 )
    -> pipe ( $ addOne )
    -> pipe ( $ addOne )
    -> pipe ( $ addOne )
    -> result ();

Interromper o pipeline

halt ()

Você pode retornar halt() de um retorno de chamada para interromper a corrente. halt toma um resultado opcional como um argumento que você pode passar como result() da cadeia. As chamadas subsequentes para ->pipe() não afetarão o resultado final.

    use function Inmanturbo  Pipes { pipe , halt };

    $ fortyFive = pipe ( 1 );

    $ count = 1 ;
    while ( $ count < 50 ) {
        $ fortyFive -> pipe ( fn ( $ number ) => $ number < 45 ? ++ $ number : halt ( $ number ));

        $ count ++;
    }

    echo $ fortyFive -> result ();

    // 45

    echo $ fortyFive -> pipe ( fn ( $ number ) => ++ $ number )-> result ();

    // 45

Você também pode chamar a parte do próprio tubo

    use function Inmanturbo  Pipes { pipe , halt };

    $ fortyFive = pipe ( 1 );

    $ count = 1 ;
    while ( $ count < 50 ) {
        
        if (( $ number = $ fortyFive -> result ()) >= 45 ) {
            $ fortyFive -> halt ( $ number );
        }

        $ fortyFive -> pipe ( fn ( $ number ) => ++ $ number );

        $ count ++;
    }

    echo $ fortyFive -> result ();

    // 45

    echo $ fortyFive -> pipe ( fn ( $ number ) => ++ $ number )-> result ();

    // 45 

retomar()

Você pode retomar a tubulação com currículo. pipe()->resume() pega um retorno de chamada opcional e se comporta o mesmo que pipe()->pipe() se um retorno de chamada for passado

 use function Inmanturbo  Pipes { pipe , halt };

$ fortySix = pipe ( 1 );

$ count = 1 ;
while ( $ count < 50 ) {
    
    if (( $ number = $ fortySix -> result ()) >= 45 ) {
        $ fortySix -> halt ( $ number );
    }

    $ fortySix -> pipe ( fn ( $ number ) => ++ $ number );

    $ count ++;
}

echo $ fortySix -> result ();

// 45

echo $ fortySix -> resume ( fn ( $ number ) => ++ $ number )-> result ();

// 46 

Hop () e Laravel

Este pacote não requer que o Laravel use tubo ou hop() , mas hop() (tubo de ordem superior) é uma função de ordem superior destinada a trabalhar com o ajudante de oleoduto de Laravel. Essa função de ordem superior leva um retorno de chamada que leva um único argumento e envolve o $callback em um fechamento que implementa function($next, $passable) .

 use Illuminate  Pipeline  Pipeline ;

use function Inmanturbo  Pipes  hop ;

class Add {
    public function add ( $ number )
    {
        return $ number + 1 ;
    }
}
class InvokeAdd {
    public function __invoke ( $ number )
    {
        return $ number + 1 ;
    }
}

$ five = ( new Pipeline )-> send ( 1 )
    -> pipe ( hop ( fn ( $ number ) => $ number + 1 ))
    -> pipe ( hop ( new InvokeAdd ))
    -> pipe ( hop (InvokeAdd::class))
    -> pipe ( hop ( fn ( $ number ) => ( new Add )-> add ( $ number )))
-> thenReturn ();

// 5

Opcionalmente, você pode passar um único middleware como um segundo argumento para hop() , e ele será chamado antes do primeiro argumento, o que permite determinar se o pipeline deve parar antes que o $callback seja executado.

 $ limitThreeMiddleware = function ( $ number , $ next ) {
    if ( $ number >= 3 ) {
        Log:: info ( ' Limit hit ' );
        return $ number ;
    }

    return $ next ( $ number );
};

$ five = ( new Pipeline )-> send ( 1 )
    -> pipe ( hop ( fn ( $ number ) => $ number + 1 , $ limitThreeMiddleware ))
    -> pipe ( hop ( new InvokeAdd , $ limitThreeMiddleware ))
    // Limit hit
    -> pipe ( hop (InvokeAdd::class, $ limitThreeMiddleware ))
    -> pipe ( hop ( fn ( $ number ) => ( new Add )-> add ( $ number ), $ limitThreeMiddleware ))
-> thenReturn ();

// 3