async/tests/UtilParallelTest.php at adc6eb04626d09d34ec026a65c46f13db9e320fd · clue-labs/async · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
<?php

namespace React\Tests\Async;

use React\Async\Util;

class UtilParallelTest extends TestCase
{
    public function testParallelWithoutTasks()
    {
        $tasks = array();

        $callback = $this->createCallableMock($this->once(), array());
        $errback = $this->createCallableMock($this->never());

        Util::parallel($tasks, $callback, $errback);
    }

    public function testParallelWithTasks()
    {
        $loop = new \React\EventLoop\StreamSelectLoop();

        $tasks = array(
            function ($callback, $errback) use ($loop) {
                $loop->addTimer(0.1, function () use ($callback) {
                    $callback('foo');
                });
            },
            function ($callback, $errback) use ($loop) {
                $loop->addTimer(0.1, function () use ($callback) {
                    $callback('bar');
                });
            },
        );

        $callback = $this->createCallableMock($this->once(), array('foo', 'bar'));
        $errback = $this->createCallableMock($this->never());

        Util::parallel($tasks, $callback, $errback);

        $timer = new Timer($this);
        $timer->start();

        $loop->run();

        $timer->stop();
        $timer->assertInRange(0.1, 0.2);
    }

    public function testParallelWithError()
    {
        $called = 0;

        $tasks = array(
            function ($callback, $errback) use (&$called) {
                $callback('foo');
                $called++;
            },
            function ($callback, $errback) {
                $e = new \RuntimeException('whoops');
                $errback($e);
            },
            function ($callback, $errback) use (&$called) {
                $callback('bar');
                $called++;
            },
        );

        $callback = $this->createCallableMock($this->never());
        $errback = $this->createCallableMock($this->once());

        Util::parallel($tasks, $callback, $errback);

        $this->assertSame(2, $called);
    }

    public function testParallelWithDelayedError()
    {
        $called = 0;

        $loop = new \React\EventLoop\StreamSelectLoop();

        $tasks = array(
            function ($callback, $errback) use (&$called) {
                $callback('foo');
                $called++;
            },
            function ($callback, $errback) use ($loop) {
                $loop->addTimer(0.001, function () use ($errback) {
                    $e = new \RuntimeException('whoops');
                    $errback($e);
                });
            },
            function ($callback, $errback) use (&$called) {
                $callback('bar');
                $called++;
            },
        );

        $callback = $this->createCallableMock($this->never());
        $errback = $this->createCallableMock($this->once());

        Util::parallel($tasks, $callback, $errback);

        $loop->run();

        $this->assertSame(2, $called);
    }
}