FactoryTest.php

<?php

use React\Datagram\Socket;
use React\Promise\When;
use React\Promise\PromiseInterface;

class FactoryTest extends TestCase
{
    private $factory;

    public function setUp()
    {
        $this->loop = React\EventLoop\Factory::create();
        $this->factory = new React\Datagram\Factory($this->loop, $this->createResolverMock());
    }

    public function testCreateClient()
    {
        $promise = $this->factory->createClient('127.0.0.1:12345');

        $capturedClient = $this->getValueFromResolvedPromise($promise);
        $this->assertInstanceOf('React\Datagram\Socket', $capturedClient);

        $capturedClient->close();
    }

    public function testCreateClientLocalhost()
    {
        $promise = $this->factory->createClient('localhost:12345');

        $capturedClient = $this->getValueFromResolvedPromise($promise);
        $this->assertInstanceOf('React\Datagram\Socket', $capturedClient);

        $capturedClient->close();
    }

    public function testCreateClientIpv6()
    {
        $promise = $this->factory->createClient('[::1]:12345');

        $capturedClient = $this->getValueFromResolvedPromise($promise);
        $this->assertInstanceOf('React\Datagram\Socket', $capturedClient);

        $capturedClient->close();
    }

    public function testCreateServer()
    {
        $promise = $this->factory->createServer('127.0.0.1:12345');

        $capturedServer = $this->getValueFromResolvedPromise($promise);
        $this->assertInstanceOf('React\Datagram\Socket', $capturedServer);

        $capturedServer->close();
    }

    public function testCreateServerRandomPort()
    {
        $promise = $this->factory->createServer('127.0.0.1:0');

        $capturedServer = $this->getValueFromResolvedPromise($promise);
        $this->assertInstanceOf('React\Datagram\Socket', $capturedServer);

        $this->assertNotEquals('127.0.0.1:0', $capturedServer->getLocalAddress());

        $capturedServer->close();
    }
}