Home
last modified time | relevance | path

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

/plugin/elasticsearch/vendor/ezimuel/guzzlestreams/src/
H A DAsyncReadStream.php36 private $needsDrain; variable in GuzzleHttp\\Stream\\AsyncReadStream
183 if (!$this->needsDrain && $this->drain) {
184 $this->needsDrain = $this->stream->getSize() >= $this->hwm;
190 if ($this->needsDrain && $this->stream->getSize() === 0) {
191 $this->needsDrain = false;
/plugin/elasticsearch/vendor/ezimuel/guzzlestreams/tests/
H A DAsyncReadStreamTest.php127 $needsDrain = new ReflectionProperty(AsyncReadStream::class, 'needsDrain');
128 $needsDrain->setAccessible(true);
131 $this->assertTrue($needsDrain->getValue($a));
137 $this->assertFalse($needsDrain->getValue($a));