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 Clue\React\Block;
use React\EventLoop\Factory;
use React\Promise\Stream;
use React\Stream\ThroughStream;

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

$promise = Stream\buffer($stream);

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

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

$promise = Stream\buffer($stream);

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

public function testClosingStreamResolvesWithEmptyBuffer()
    {
        $stream = new ThroughStream();
        $promise = Stream\buffer($stream);

$stream->close();

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

public function testEmittingDataOnStreamResolvesWithConcatenatedData()
    {
        $stream = new ThroughStream();
        $promise = Stream\buffer($stream);

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

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

public function testEmittingErrorOnStreamRejects()
    {
        $stream = new ThroughStream();
        $promise = Stream\buffer($stream);

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

$this->expectPromiseReject($promise);
    }

public function testEmittingErrorAfterEmittingDataOnStreamRejects()
    {
        $stream = new ThroughStream();
        $promise = Stream\buffer($stream);

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

$this->expectPromiseReject($promise);
    }

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

$promise = Stream\buffer($stream);

$promise->cancel();

$this->expectPromiseReject($promise);
    }

public function testMaximumSize()
    {
        $loop = Factory::create();
        $stream = new ThroughStream();

$loop->addTimer(0.1, function () use ($stream) {
            $stream->write('12345678910111213141516');
        });

$promise = Stream\buffer($stream, 16);

if (method_exists($this, 'expectException')) {
            $this->expectException('OverflowException');
            $this->expectExceptionMessage('Buffer exceeded maximum length');
        } else {
            $this->setExpectedException('\OverflowException', 'Buffer exceeded maximum length');
        }
        Block\await($promise, $loop, 10);
    }

public function testUnderMaximumSize()
    {
        $loop = Factory::create();
        $stream = new ThroughStream();

$loop->addTimer(0.1, function () use ($stream) {
            $stream->write('1234567891011');
            $stream->end();
        });

$promise = Stream\buffer($stream, 16);

$result = Block\await($promise, $loop, 10);
        $this->assertSame('1234567891011', $result);
    }
}