Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
AppendStreamTest.php	5.7 KB	-rw-r--r--	2018-01-15 09:00
BufferStreamTest.php	1.9 KB	-rw-r--r--	2018-01-15 09:00
CachingStreamTest.php	5.54 KB	-rw-r--r--	2018-01-15 09:00
DroppingStreamTest.php	919 B	-rw-r--r--	2018-01-15 09:00
FnStreamTest.php	2.55 KB	-rw-r--r--	2018-01-15 09:00
FunctionsTest.php	20.76 KB	-rw-r--r--	2018-01-15 09:00
InflateStreamTest.php	446 B	-rw-r--r--	2018-01-15 09:00
LazyOpenStreamTest.php	1.8 KB	-rw-r--r--	2018-01-15 09:00
LimitStreamTest.php	4.87 KB	-rw-r--r--	2018-01-15 09:00
MultipartStreamTest.php	5.24 KB	-rw-r--r--	2018-01-15 09:00
NoSeekStreamTest.php	1.12 KB	-rw-r--r--	2018-01-15 09:00
PumpStreamTest.php	2.17 KB	-rw-r--r--	2018-01-15 09:00
RequestTest.php	4.71 KB	-rw-r--r--	2018-01-15 09:00
ResponseTest.php	4.73 KB	-rw-r--r--	2018-01-15 09:00
ServerRequestTest.php	2.55 KB	-rw-r--r--	2018-01-15 09:00
StreamDecoratorTraitTest.php	3.22 KB	-rw-r--r--	2018-01-15 09:00
StreamTest.php	5.03 KB	-rw-r--r--	2018-01-15 09:00
StreamWrapperTest.php	3.12 KB	-rw-r--r--	2018-01-15 09:00
UriTest.php	10.18 KB	-rw-r--r--	2018-01-15 09:00
bootstrap.php	197 B	-rw-r--r--	2018-01-15 09:00

Rename

<?php
namespace RingCentral\Tests\Psr7;

use RingCentral\Psr7\LimitStream;
use RingCentral\Psr7\PumpStream;
use RingCentral\Psr7;

class PumpStreamTest extends \PHPUnit_Framework_TestCase
{
    public function testHasMetadataAndSize()
    {
        $p = new PumpStream(function () {}, array(
            'metadata' => array('foo' => 'bar'),
            'size'     => 100
        ));

$this->assertEquals('bar', $p->getMetadata('foo'));
        $this->assertEquals(array('foo' => 'bar'), $p->getMetadata());
        $this->assertEquals(100, $p->getSize());
    }

public function testCanReadFromCallable()
    {
        $p = Psr7\stream_for(function ($size) {
            return 'a';
        });
        $this->assertEquals('a', $p->read(1));
        $this->assertEquals(1, $p->tell());
        $this->assertEquals('aaaaa', $p->read(5));
        $this->assertEquals(6, $p->tell());
    }

public function testStoresExcessDataInBuffer()
    {
        $called = array();
        $p = Psr7\stream_for(function ($size) use (&$called) {
            $called[] = $size;
            return 'abcdef';
        });
        $this->assertEquals('a', $p->read(1));
        $this->assertEquals('b', $p->read(1));
        $this->assertEquals('cdef', $p->read(4));
        $this->assertEquals('abcdefabc', $p->read(9));
        $this->assertEquals(array(1, 9, 3), $called);
    }

public function testInifiniteStreamWrappedInLimitStream()
    {
        $p = Psr7\stream_for(function () { return 'a'; });
        $s = new LimitStream($p, 5);
        $this->assertEquals('aaaaa', (string) $s);
    }

public function testDescribesCapabilities()
    {
        $p = Psr7\stream_for(function () {});
        $this->assertTrue($p->isReadable());
        $this->assertFalse($p->isSeekable());
        $this->assertFalse($p->isWritable());
        $this->assertNull($p->getSize());
        $this->assertEquals('', $p->getContents());
        $this->assertEquals('', (string) $p);
        $p->close();
        $this->assertEquals('', $p->read(10));
        $this->assertTrue($p->eof());

try {
            $this->assertFalse($p->write('aa'));
            $this->fail();
        } catch (\RuntimeException $e) {}
    }
}