class CachingStreamTest in Zircon Profile 8
Same name and namespace in other branches
- 8.0 vendor/guzzlehttp/psr7/tests/CachingStreamTest.php \GuzzleHttp\Tests\Psr7\CachingStreamTest
@covers GuzzleHttp\Psr7\CachingStream
Hierarchy
- class \GuzzleHttp\Tests\Psr7\CachingStreamTest extends \GuzzleHttp\Tests\Psr7\PHPUnit_Framework_TestCase
Expanded class hierarchy of CachingStreamTest
File
- vendor/
guzzlehttp/ psr7/ tests/ CachingStreamTest.php, line 10
Namespace
GuzzleHttp\Tests\Psr7View source
class CachingStreamTest extends \PHPUnit_Framework_TestCase {
/** @var CachingStream */
protected $body;
protected $decorated;
public function setUp() {
$this->decorated = Psr7\stream_for('testing');
$this->body = new CachingStream($this->decorated);
}
public function tearDown() {
$this->decorated
->close();
$this->body
->close();
}
public function testUsesRemoteSizeIfPossible() {
$body = Psr7\stream_for('test');
$caching = new CachingStream($body);
$this
->assertEquals(4, $caching
->getSize());
}
public function testReadsUntilCachedToByte() {
$this->body
->seek(5);
$this
->assertEquals('n', $this->body
->read(1));
$this->body
->seek(0);
$this
->assertEquals('t', $this->body
->read(1));
}
public function testCanSeekNearEndWithSeekEnd() {
$baseStream = Psr7\stream_for(implode('', range('a', 'z')));
$cached = new CachingStream($baseStream);
$cached
->seek(1, SEEK_END);
$this
->assertEquals(24, $baseStream
->tell());
$this
->assertEquals('y', $cached
->read(1));
$this
->assertEquals(26, $cached
->getSize());
}
public function testCanSeekToEndWithSeekEnd() {
$baseStream = Psr7\stream_for(implode('', range('a', 'z')));
$cached = new CachingStream($baseStream);
$cached
->seek(0, SEEK_END);
$this
->assertEquals(25, $baseStream
->tell());
$this
->assertEquals('z', $cached
->read(1));
$this
->assertEquals(26, $cached
->getSize());
}
public function testCanUseSeekEndWithUnknownSize() {
$baseStream = Psr7\stream_for('testing');
$decorated = Psr7\FnStream::decorate($baseStream, [
'getSize' => function () {
return null;
},
]);
$cached = new CachingStream($decorated);
$cached
->seek(1, SEEK_END);
$this
->assertEquals('ng', $cached
->read(2));
}
public function testRewindUsesSeek() {
$a = Psr7\stream_for('foo');
$d = $this
->getMockBuilder('GuzzleHttp\\Psr7\\CachingStream')
->setMethods(array(
'seek',
))
->setConstructorArgs(array(
$a,
))
->getMock();
$d
->expects($this
->once())
->method('seek')
->with(0)
->will($this
->returnValue(true));
$d
->seek(0);
}
public function testCanSeekToReadBytes() {
$this
->assertEquals('te', $this->body
->read(2));
$this->body
->seek(0);
$this
->assertEquals('test', $this->body
->read(4));
$this
->assertEquals(4, $this->body
->tell());
$this->body
->seek(2);
$this
->assertEquals(2, $this->body
->tell());
$this->body
->seek(2, SEEK_CUR);
$this
->assertEquals(4, $this->body
->tell());
$this
->assertEquals('ing', $this->body
->read(3));
}
public function testWritesToBufferStream() {
$this->body
->read(2);
$this->body
->write('hi');
$this->body
->seek(0);
$this
->assertEquals('tehiing', (string) $this->body);
}
public function testSkipsOverwrittenBytes() {
$decorated = Psr7\stream_for(implode("\n", array_map(function ($n) {
return str_pad($n, 4, '0', STR_PAD_LEFT);
}, range(0, 25))));
$body = new CachingStream($decorated);
$this
->assertEquals("0000\n", Psr7\readline($body));
$this
->assertEquals("0001\n", Psr7\readline($body));
// Write over part of the body yet to be read, so skip some bytes
$this
->assertEquals(5, $body
->write("TEST\n"));
$this
->assertEquals(5, $this
->readAttribute($body, 'skipReadBytes'));
// Read, which skips bytes, then reads
$this
->assertEquals("0003\n", Psr7\readline($body));
$this
->assertEquals(0, $this
->readAttribute($body, 'skipReadBytes'));
$this
->assertEquals("0004\n", Psr7\readline($body));
$this
->assertEquals("0005\n", Psr7\readline($body));
// Overwrite part of the cached body (so don't skip any bytes)
$body
->seek(5);
$this
->assertEquals(5, $body
->write("ABCD\n"));
$this
->assertEquals(0, $this
->readAttribute($body, 'skipReadBytes'));
$this
->assertEquals("TEST\n", Psr7\readline($body));
$this
->assertEquals("0003\n", Psr7\readline($body));
$this
->assertEquals("0004\n", Psr7\readline($body));
$this
->assertEquals("0005\n", Psr7\readline($body));
$this
->assertEquals("0006\n", Psr7\readline($body));
$this
->assertEquals(5, $body
->write("1234\n"));
$this
->assertEquals(5, $this
->readAttribute($body, 'skipReadBytes'));
// Seek to 0 and ensure the overwritten bit is replaced
$body
->seek(0);
$this
->assertEquals("0000\nABCD\nTEST\n0003\n0004\n0005\n0006\n1234\n0008\n0009\n", $body
->read(50));
// Ensure that casting it to a string does not include the bit that was overwritten
$this
->assertContains("0000\nABCD\nTEST\n0003\n0004\n0005\n0006\n1234\n0008\n0009\n", (string) $body);
}
public function testClosesBothStreams() {
$s = fopen('php://temp', 'r');
$a = Psr7\stream_for($s);
$d = new CachingStream($a);
$d
->close();
$this
->assertFalse(is_resource($s));
}
/**
* @expectedException \InvalidArgumentException
*/
public function testEnsuresValidWhence() {
$this->body
->seek(10, -123456);
}
}
Members
Name | Modifiers | Type | Description | Overrides |
---|---|---|---|---|
CachingStreamTest:: |
protected | property | @var CachingStream | |
CachingStreamTest:: |
protected | property | ||
CachingStreamTest:: |
public | function | ||
CachingStreamTest:: |
public | function | ||
CachingStreamTest:: |
public | function | ||
CachingStreamTest:: |
public | function | ||
CachingStreamTest:: |
public | function | ||
CachingStreamTest:: |
public | function | ||
CachingStreamTest:: |
public | function | ||
CachingStreamTest:: |
public | function | @expectedException \InvalidArgumentException | |
CachingStreamTest:: |
public | function | ||
CachingStreamTest:: |
public | function | ||
CachingStreamTest:: |
public | function | ||
CachingStreamTest:: |
public | function | ||
CachingStreamTest:: |
public | function |