Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
AllTest.php	2.9 KB	-rw-r--r--	2017-12-22 09:00
BufferTest.php	3.13 KB	-rw-r--r--	2017-12-22 09:00
CallableStub.php	112 B	-rw-r--r--	2017-12-22 09:00
FirstTest.php	2.6 KB	-rw-r--r--	2017-12-22 09:00
TestCase.php	2.11 KB	-rw-r--r--	2017-12-22 09:00
UnwrapReadableTest.php	7.84 KB	-rw-r--r--	2017-12-22 09:00
UnwrapWritableTest.php	9.7 KB	-rw-r--r--	2017-12-22 09:00

Rename

<?php

namespace React\Tests\Promise\Stream;

use React\Promise\Stream;
use React\Stream\ThroughStream;

class FirstTest extends TestCase
{
    public function testClosedReadableStreamRejects()
    {
        $stream = new ThroughStream();
        $stream->close();

$promise = Stream\first($stream);

$this->expectPromiseReject($promise);
    }

public function testClosedWritableStreamRejects()
    {
        $stream = new ThroughStream();
        $stream->close();

$promise = Stream\first($stream);

$this->expectPromiseReject($promise);
    }

public function testPendingStreamWillNotResolve()
    {
        $stream = new ThroughStream();

$promise = Stream\first($stream);

$promise->then($this->expectCallableNever(), $this->expectCallableNever());
    }

public function testClosingStreamRejects()
    {
        $stream = new ThroughStream();
        $promise = Stream\first($stream);

$stream->close();

$this->expectPromiseReject($promise);
    }

public function testClosingWritableStreamRejects()
    {
        $stream = new ThroughStream();
        $promise = Stream\first($stream);

$stream->close();

$this->expectPromiseReject($promise);
    }

public function testClosingStreamResolvesWhenWaitingForCloseEvent()
    {
        $stream = new ThroughStream();
        $promise = Stream\first($stream, 'close');

$stream->close();

$this->expectPromiseResolve($promise);
    }

public function testEmittingDataOnStreamResolvesWithFirstEvent()
    {
        $stream = new ThroughStream();
        $promise = Stream\first($stream);

$stream->emit('data', array('hello', $stream));
        $stream->emit('data', array('world', $stream));
        $stream->close();

$this->expectPromiseResolveWith('hello', $promise);
    }

public function testEmittingErrorOnStreamWillReject()
    {
        $stream = new ThroughStream();
        $promise = Stream\first($stream);

$stream->emit('error', array(new \RuntimeException('test')));

$this->expectPromiseReject($promise);
    }

public function testEmittingErrorResolvesWhenWaitingForErrorEvent()
    {
        $stream = new ThroughStream();
        $promise = Stream\first($stream, 'error');

$stream->emit('error', array(new \RuntimeException('test')));

$this->expectPromiseResolve($promise);
    }

public function testCancelPendingStreamWillReject()
    {
        $stream = new ThroughStream();

$promise = Stream\first($stream);

$promise->cancel();

$this->expectPromiseReject($promise);
    }
}