FM / Loop

/home/techb158/exp.abdallabala.com/vendor/sabre/event/tests/Loop/

/home/techb158/exp.abdallabala.com/vendor/sabre/event/tests/Loop

Name	Size	Mode	Actions
FunctionsTest.php	2708	0644	edit dl rm
LoopTest.php	3388	0644	edit dl rm

Edit: /home/techb158/exp.abdallabala.com/vendor/sabre/event/tests/Loop/LoopTest.php (3388B)

<?php

namespace Sabre\Event\Loop;

class LoopTest extends \PHPUnit_Framework_TestCase {

function testNextTick() {

$loop = new Loop();
        $check  = 0;
        $loop->nextTick(function() use (&$check) {

$check++;

});

$loop->run();

$this->assertEquals(1, $check);

}

function testTimeout() {

$loop = new Loop();
        $check  = 0;
        $loop->setTimeout(function() use (&$check) {

$check++;

}, 0.02);

$loop->run();

$this->assertEquals(1, $check);

}

function testTimeoutOrder() {

$loop = new Loop();
        $check  = [];
        $loop->setTimeout(function() use (&$check) {

$check[] = 'a';

}, 0.2);
        $loop->setTimeout(function() use (&$check) {

$check[] = 'b';

}, 0.1);
        $loop->setTimeout(function() use (&$check) {

$check[] = 'c';

}, 0.3);

$loop->run();

$this->assertEquals(['b', 'a', 'c'], $check);

}

function testSetInterval() {

$loop = new Loop();
        $check = 0;
        $intervalId = null;
        $intervalId = $loop->setInterval(function() use (&$check, &$intervalId, $loop) {

$check++;
            if ($check > 5) {
                $loop->clearInterval($intervalId);
            }

}, 0.02);

$loop->run();
        $this->assertEquals(6, $check);

}

function testAddWriteStream() {

$h = fopen('php://temp', 'r+');
        $loop = new Loop();
        $loop->addWriteStream($h, function() use ($h, $loop) {

fwrite($h, 'hello world');
            $loop->removeWriteStream($h);

});
        $loop->run();
        rewind($h);
        $this->assertEquals('hello world', stream_get_contents($h));

}

function testAddReadStream() {

$h = fopen('php://temp', 'r+');
        fwrite($h, 'hello world');
        rewind($h);

$loop = new Loop();

$result = null;

$loop->addReadStream($h, function() use ($h, $loop, &$result) {

$result = fgets($h);
            $loop->removeReadStream($h);

});
        $loop->run();
        $this->assertEquals('hello world', $result);

}

function testStop() {

$check = 0;
        $loop = new Loop();
        $loop->setTimeout(function() use (&$check) {
            $check++;
        }, 200);

$loop->nextTick(function() use ($loop) {
            $loop->stop();
        });
        $loop->run();

$this->assertEquals(0, $check);

}

function testTick() {

$check = 0;
        $loop = new Loop();
        $loop->setTimeout(function() use (&$check) {
            $check++;
        }, 1);

$loop->nextTick(function() use ($loop, &$check) {
            $check++;
        });
        $loop->tick();

$this->assertEquals(1, $check);

}

/**
     * Here we add a new nextTick function as we're in the middle of a current
     * nextTick.
     */
    function testNextTickStacking() {

$loop = new Loop();
        $check  = 0;
        $loop->nextTick(function() use (&$check, $loop) {

$loop->nextTick(function() use (&$check) {

$check++;

});
            $check++;

});

$loop->run();

$this->assertEquals(2, $check);

}

cmd: