amp/test/LoopTest.php

<?php

namespace Amp\Test;

use Amp\Loop;
use PHPUnit\Framework\TestCase;

class LoopTest extends TestCase
{
    public function testDelayWithNegativeDelay()
    {
        $this->expectException(\Error::class);

        Loop::delay(-1, function () {
        });
    }

    public function testRepeatWithNegativeInterval()
    {
        $this->expectException(\Error::class);

        Loop::repeat(-1, function () {
        });
    }

    public function testOnReadable()
    {
        Loop::run(function () {
            $ends = \stream_socket_pair(\stripos(PHP_OS, "win") === 0 ? STREAM_PF_INET : STREAM_PF_UNIX, STREAM_SOCK_STREAM, STREAM_IPPROTO_IP);
            \fwrite($ends[0], "trigger readability watcher");

            Loop::onReadable($ends[1], function () {
                $this->assertTrue(true);
                Loop::stop();
            });
        });
    }

    public function testOnWritable()
    {
        Loop::run(function () {
            Loop::onWritable(STDOUT, function () {
                $this->assertTrue(true);
                Loop::stop();
            });
        });
    }

    public function testGet()
    {
        $this->assertInstanceOf(Loop\Driver::class, Loop::get());
    }

    public function testGetInto()
    {
        $this->assertSame(Loop::get()->getInfo(), Loop::getInfo());
    }
}