Lines Matching refs:AsyncReadStream
4 use GuzzleHttp\Stream\AsyncReadStream; alias
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();
151 list($buffer, $async) = AsyncReadStream::create(['buffer' => $buf]);
158 list($buffer, $async) = AsyncReadStream::create(['max_buffer' => 0]);
165 list($buffer, $async) = AsyncReadStream::create(['max_buffer' => 5]);
176 list($buffer, $async) = AsyncReadStream::create([