Home
last modified time | relevance | path

Searched refs:AsyncReadStream (Results 1 – 2 of 2) sorted by relevance

/plugin/elasticsearch/vendor/ezimuel/guzzlestreams/tests/
H A DAsyncReadStreamTest.php4 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
[all...]
/plugin/elasticsearch/vendor/ezimuel/guzzlestreams/src/
H A DAsyncReadStream.php8 * The AsyncReadStream can be used as a completely asynchronous stream, meaning
12 * AsyncReadStream can also be used in a "blocking" manner if a "pump" function
22 class AsyncReadStream implements StreamInterface class
108 * This function accepts the same options as AsyncReadStream::__construct,
130 * data, followed by the ready to use AsyncReadStream object.