Lines Matching defs:AsyncReadStream

4 use GuzzleHttp\Stream\AsyncReadStream;
18         new AsyncReadStream(FnStream::decorate(
28         new AsyncReadStream(FnStream::decorate(
36         $a = new AsyncReadStream(Stream::factory(), [
39         $drain = new ReflectionProperty(AsyncReadStream::class, 'drain');
48         new AsyncReadStream(new BufferStream(), ['pump' => true]);
55         new AsyncReadStream(new BufferStream(), ['drain' => true]);
61         $a = new AsyncReadStream($buffer, [
66         $size = new ReflectionProperty(AsyncReadStream::class, 'size');
68         $drain = new ReflectionProperty(AsyncReadStream::class, 'drain');
70         $pump = new ReflectionProperty(AsyncReadStream::class, 'pump');
86         $a = new AsyncReadStream($buffer);
97         $a = new AsyncReadStream($buffer, [
116         $a = new AsyncReadStream($buffer, [
127         $needsDrain = new ReflectionProperty(AsyncReadStream::class, 'needsDrain');
143         list($buffer, $async) = AsyncReadStream::create();
145         $this->assertInstanceOf('GuzzleHttp\Stream\AsyncReadStream', $async);
151         list($buffer, $async) = AsyncReadStream::create(['buffer' => $buf]);
153         $this->assertInstanceOf('GuzzleHttp\Stream\AsyncReadStream', $async);
158         list($buffer, $async) = AsyncReadStream::create(['max_buffer' => 0]);
160         $this->assertInstanceOf('GuzzleHttp\Stream\AsyncReadStream', $async);
165         list($buffer, $async) = AsyncReadStream::create(['max_buffer' => 5]);
167         $this->assertInstanceOf('GuzzleHttp\Stream\AsyncReadStream', $async);
176         list($buffer, $async) = AsyncReadStream::create([
185         $this->assertInstanceOf('GuzzleHttp\Stream\AsyncReadStream', $async);