pipes

أنابيب PHP مع واجهة برمجة تطبيقات بسيطة على أساس تكوين وظيفي

ببساطة ، يأخذ إخراج آخر واحد ويقوم بتنشيطه إلى واحد التالي. نوعا ما مثل باش cat ./file | grep -e 'waldo'

تثبيت

يمكنك تثبيت الحزمة عبر الملحن:

composer require inmanturbo/pipes

أو مجرد نسخ أو تنزيل ملف functions.php من هذا المستودع.

الاستخدام

ماسورة()

 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

لا يؤخر التنفيذ

 $ fifty = pipe ( 1 );

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

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

يمكنك أيضًا تمرير فئة أو سلسلة فئة

 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 ();

نتائج العودة

يمكن إرجاع النتائج ثلاث طرق:

then() أو thenReturn() كلاهما يأخذ رد الاتصال النهائي وإرجاع النتيجة ، أو result() ، والتي تُرجع النتيجة ببساطة.

 $ 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 ();

وقف خط الأنابيب

وقف()

يمكنك إرجاع halt() من رد الاتصال لوقف السلسلة. يأخذ halt نتيجة اختيارية كوسيطة يمكنك نقلها كنتيجة نهائية result() للسلسلة. لن تؤثر المكالمات اللاحقة إلى ->pipe() على النتيجة النهائية.

    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

يمكنك أيضًا استدعاء التوقف على الأنبوب نفسه

    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 

سيرة ذاتية()

يمكنك استئناف الأنابيب مع السيرة الذاتية. pipe()->resume() يأخذ رد اتصال اختياري ويتصرف بنفس القدر من pipe()->pipe() إذا تم تمرير رد الاتصال

 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 

قفزة () و laravel

لا تتطلب هذه الحزمة Laravel استخدام الأنابيب أو hop() ، ولكن hop() (أنبوب المرتبة العليا) هي وظيفة ترتيب أعلى مخصصة للعمل مع مساعد خط أنابيب Laravel. يأخذ هذا الوظيفة ذات الترتيب العالي رد الاتصال الذي يأخذ وسيطة واحدة ، ويلتف $callback لك في إغلاق يتنفس 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

يمكنك اختياريًا تمرير middleware واحدة كوسيطة ثانية لـ hop() ، وسيتم استدعاؤها قبل الوسيطة الأولى ، والتي تتيح لك تحديد ما إذا كان خط الأنابيب يجب أن يتوقف قبل تنفيذ $callback على الإطلاق.

 $ 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