amp/test/AsyncCoroutineTest.php

<?php

namespace Amp\Test;

use Amp;
use Amp\Failure;
use Amp\Loop;
use PHPUnit\Framework\TestCase;

class AsyncCoroutineTest extends TestCase {
    public function testWithFailure() {
        $coroutine = Amp\asyncCoroutine(function ($value) {
            return new Failure(new Amp\PHPUnit\TestException);
        });

        $coroutine(42);

        $this->expectException(Amp\PHPUnit\TestException::class);

        Loop::run();
    }
}