rx-batch/rx-batch

1.0.4 2021-09-20 06:09 UTC

Requires

• react/event-loop: ^1.2
• reactivex/rxphp: ^2.0
• rx/http: ^2.1

Requires (Dev)

• mockery/mockery: ^1.4
• phpunit/phpunit: ^9.5

Apache-2.0

• Gleb Vasylenko

README

Library for processing miltiple observables as single batch uses RxPHP.

Use Case

<?php

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

use Rx\Observable;
use Rx\React\Http;
use RxBatch\Batch;

$resources = [
    'task_1' => Http::get('https://www.google.com'),
    'task_2' => Http::get('https://www.google.com'),
    'task_3' => Observable::of('Result 3'),
];

Batch::of($resources)->subscribe(
    function($data) {
        print_r($data['task_1']);
        print_r($data['task_2']);
        print_r($data['task_3']);
    },
    function($e) {
        echo $e->getMessage();
    },
);