parallel/tests/Threading/LocalObjectTest.php

<?php
namespace Icicle\Tests\Concurrent\Threading;

use Icicle\Concurrent\Threading\LocalObject;
use Icicle\Promise\Promise;
use Icicle\Tests\Concurrent\TestCase;

/**
 * @group threading
 */
class LocalObjectTest extends TestCase
{
    public function testConstructor()
    {
        $object = new LocalObject(new \stdClass());
        $this->assertInternalType('object', $object->deref());
    }

    public function testClosureObject()
    {
        $object = new LocalObject(function () {});
        $this->assertInstanceOf('Closure', $object->deref());
    }

    public function testResource()
    {
        $object = new LocalObject(new \stdClass());
        $object->deref()->resource = fopen(__FILE__, 'r');
        $this->assertInternalType('resource', $object->deref()->resource);
        fclose($object->deref()->resource);
    }

    /**
     * @expectedException \Icicle\Concurrent\Exception\InvalidArgumentError
     */
    public function testNonObjectThrowsError()
    {
        $object = new LocalObject(42);
    }

    public function testDerefIsOfCorrectType()
    {
        $object = new LocalObject(new \stdClass());
        $this->assertInstanceOf('stdClass', $object->deref());
    }

    public function testDerefIsSameObject()
    {
        $object = new \stdClass();
        $local = new LocalObject($object);
        $this->assertSame($object, $local->deref());
    }

    public function testNewObjectIsNotFreed()
    {
        $object = new LocalObject(new \stdClass());
        $this->assertFalse($object->isFreed());
    }

    public function testFreeReleasesObject()
    {
        $object = new LocalObject(new \stdClass());
        $object->free();
        $this->assertTrue($object->isFreed());
    }

    /**
     * @expectedException \Icicle\Concurrent\Exception\LocalObjectError
     */
    public function testDerefThrowsErrorIfFreed()
    {
        $object = new LocalObject(new \stdClass());
        $object->free();
        $object->deref();
    }

    public function testSerializeDoesntAffectObject()
    {
        $object = new \stdClass();
        $local = new LocalObject($object);
        $local = unserialize(serialize($local));
        $this->assertSame($object, $local->deref());
    }

    /**
     * @requires extension pthreads
     */
    public function testPromiseInThread()
    {
        $thread = \Thread::from(function () {
            require __DIR__.'/../../vendor/autoload.php';
            $promise = new LocalObject(new Promise(function ($resolve, $reject) {}));
        });

        $thread->start();
        $thread->join();
    }

    public function testCloneIsNewObject()
    {
        $object = new \stdClass();
        $local = new LocalObject($object);
        $clone = clone $local;
        $this->assertNotSame($local, $clone);
        $this->assertNotSame($object, $clone->deref());
        $this->assertNotEquals($local->__debugInfo()['id'], $clone->__debugInfo()['id']);
    }
}