rx/swoole

RxPHP Swoole

RxPHP Swoole

This project allows you to use RxPHP with Swoole., _(*1)

Installation

First, install swoole, _(*2)

Then add rx/swoole to your project with composer:, _(*3)

    composer require rx/swoole

It bootstraps a swoole scheduler for you, so you can do things like:, _(*4)

  \Rx\Observable::interval(1000)
    ->take(5)
    ->subscribe(function($i){
      echo $i, PHP_EOL;
    });

Use with other Swoole modules

A small number of Swoole modules have helper Rx wrappers in this library. You can use these to combine into more complex examples:, _(*5)

// this example uses the rx/operator-extras package for `cut`

$file = \Rx\Swoole\Async::read(__DIR__ . '/url_list.txt');

$urlInfo = $file
    ->cut("\n")
    ->flatMap(function ($url) {
        return \Rx\Swoole\Http::get($url)
            ->map(function ($content) use ($url) {
                return $url . " is " . strlen($content) . " bytes.\n";
            });
    });

$urlInfo->subscribe(function ($info) {
        echo $info;
    });