Lines Matching refs:buffer

60         $buffer = new BufferStream();
61         $a = new AsyncReadStream($buffer, [
73         $this->assertSame($buffer, $a->stream);
85         $buffer = new BufferStream();
86         $a = new AsyncReadStream($buffer);
87         $buffer->write('foo');
96         $buffer = new BufferStream();
97         $a = new AsyncReadStream($buffer, [
103         $buffer->write('foobar');
115         $buffer = new BufferStream(5);
116         $a = new AsyncReadStream($buffer, [
117             'drain' => function (BufferStream $b) use (&$called, $buffer) {
118                 $this->assertSame($b, $buffer);
123         $buffer->write('foobar');
124         $this->assertEquals(6, $buffer->getSize());
132         $this->assertEquals(3, $buffer->getSize());
136         $this->assertEquals(0, $buffer->getSize());
143         list($buffer, $async) = AsyncReadStream::create();
144         $this->assertInstanceOf('GuzzleHttp\Stream\BufferStream', $buffer);
151         list($buffer, $async) = AsyncReadStream::create(['buffer' => $buf]);
152         $this->assertSame($buf, $buffer);
158         list($buffer, $async) = AsyncReadStream::create(['max_buffer' => 0]);
159         $this->assertInstanceOf('GuzzleHttp\Stream\NullStream', $buffer);
165         list($buffer, $async) = AsyncReadStream::create(['max_buffer' => 5]);
166         $this->assertInstanceOf('GuzzleHttp\Stream\DroppingStream', $buffer);
168         $buffer->write('12345678910');
169         $this->assertEquals(5, $buffer->getSize());
176         list($buffer, $async) = AsyncReadStream::create([
177             'buffer' => $b,
184         $this->assertInstanceOf('GuzzleHttp\Stream\FnStream', $buffer);
187         $this->assertEquals(3, $buffer->write('foo'));
189         $this->assertEquals(3, $buffer->write('foo'));
191         $this->assertEquals('foofoo', (string) $buffer);