file/test/ParallelHandleTest.php

<?php declare(strict_types = 1);

namespace Amp\File\Test;

use Amp\Parallel\Worker\DefaultPool;

class ParallelHandleTest extends HandleTest {
    protected function lRun(callable $cb) {
        \Interop\Async\Loop::execute(function() use ($cb) {
            \Amp\File\filesystem(new \Amp\File\ParallelDriver(new DefaultPool));
            \Amp\rethrow(new \Amp\Coroutine($cb()));
        });
    }
}