<?php

namespace Amp\Sync\Test;

use Amp\Delayed;
use Amp\PHPUnit\AsyncTestCase;
use Amp\Sync\LocalMutex;
use function Amp\Sync\synchronized;

class SynchronizedTest extends AsyncTestCase
{
    public function testSynchronized(): \Generator
    {
        $this->setMinimumRuntime(300);

        $mutex = new LocalMutex;
        $callback = function (int $value) {
            return yield new Delayed(100, $value);
        };

        $promises = [];
        foreach (\range(0, 2) as $value) {
            $promises[] = synchronized($mutex, $callback, $value);
        }
        $result = yield $promises;
        $this->assertSame(\range(0, 2), $result);
    }
}