parallel/test/Sync/AbstractParcelTest.php

<?php

namespace Amp\Parallel\Test\Sync;

use Amp\Parallel\Sync\Parcel;
use Amp\PHPUnit\AsyncTestCase;

abstract class AbstractParcelTest extends AsyncTestCase
{
    abstract protected function createParcel($value): Parcel;

    public function testUnwrapIsOfCorrectType()
    {
        $object = $this->createParcel(new \stdClass);
        $this->assertInstanceOf('stdClass', yield $object->unwrap());
    }

    public function testUnwrapIsEqual()
    {
        $object = new \stdClass;
        $shared = $this->createParcel($object);
        $this->assertEquals($object, yield $shared->unwrap());
    }

    /**
     * @depends testUnwrapIsEqual
     */
    public function testSynchronized()
    {
        $parcel = $this->createParcel(0);

        $awaitable = $parcel->synchronized(function ($value) {
            $this->assertSame(0, $value);
            \usleep(10000);
            return 1;
        });

        $callback = $this->createCallback(1);
        $callback->method('__invoke')
            ->with($this->identicalTo(null), $this->identicalTo(1));

        $awaitable->onResolve($callback);

        $awaitable = $parcel->synchronized(function ($value) {
            $this->assertSame(1, $value);
            \usleep(10000);
            return 2;
        });

        $callback = $this->createCallback(1);
        $callback->method('__invoke')
            ->with($this->identicalTo(null), $this->identicalTo(2));

        $awaitable->onResolve($callback);
    }
}