/plugin/elasticsearch/vendor/ezimuel/guzzlestreams/src/ |
H A D | AppendStream.php | 9 * This is a read-only stream decorator. 22 * @param StreamInterface[] $streams Streams to decorate. Each stream must 27 foreach ($streams as $stream) { 28 $this->addStream($stream); 43 * Add a stream to the AppendStream 45 * @param StreamInterface $stream Stream to append. Must be readable. 47 * @throws \InvalidArgumentException if the stream is not readable 49 public function addStream(StreamInterface $stream) argument 51 if (!$stream->isReadable()) { 52 throw new \InvalidArgumentException('Each stream mus 95 attach($stream) global() argument [all...] |
H A D | AsyncReadStream.php | 5 * Represents an asynchronous read-only stream that supports a drain event and 6 * pumping data from a source stream. 8 * The AsyncReadStream can be used as a completely asynchronous stream, meaning 9 * the data you can read from the stream will immediately return only 15 * of bytes are available or the remote source stream has errored, closed, or 43 * provided stream must answer to the "hwm" stream metadata variable, 49 * - drain: (callable) Function to invoke when the stream has drained, 52 * The function accepts a single argument, the buffer stream object that 55 * from the source stream [all...] |
H A D | BufferStream.php | 7 * Provides a buffer stream that can be written to to fill a buffer, and read 10 * This stream returns a "hwm" metadata value that tells upstream consumers 11 * what the configured high water mark of the stream is, or the maximum 56 public function attach($stream) argument
|
H A D | CachingStream.php | 8 * read stream. 21 * We will treat the buffer object as the body of the stream 23 * @param StreamInterface $stream Stream to cache 27 StreamInterface $stream, argument 30 $this->remoteStream = $stream; 31 $this->stream = $target ?: new Stream(fopen('php://temp', 'r+')); 36 return max($this->stream->getSize(), $this->remoteStream->getSize()); 42 * past the total size of the buffer stream 54 // You cannot skip ahead past where you've read from the remote stream 55 if ($byte > $this->stream [all...] |
H A D | DroppingStream.php | 6 * stream becomes too full. 15 * @param StreamInterface $stream Underlying stream to decorate. 18 public function __construct(StreamInterface $stream, $maxLength) argument 20 $this->stream = $stream; 26 $diff = $this->maxLength - $this->stream->getSize(); 28 // Begin returning false when the underlying stream is too large. 33 // Write the stream or a subset of the stream i [all...] |
H A D | FnStream.php | 5 * Compose stream implementations based on a hash of functions. 7 * Allows for easy testing and extension of a provided stream without needing 44 * The close method is called on the underlying stream only if possible. 54 * Adds custom functionality to an underlying stream by intercepting 57 * @param StreamInterface $stream Stream to decorate 62 public static function decorate(StreamInterface $stream, array $methods) argument 65 // proxy to the decorated stream. 67 $methods[$diff] = [$stream, $diff]; 88 public function attach($stream) argument 90 return call_user_func($this->_fn_attach, $stream); [all...] |
H A D | GuzzleStreamWrapper.php | 5 * Converts Guzzle streams into PHP stream resources. 13 private $stream; variable in GuzzleHttp\\Stream\\GuzzleStreamWrapper 19 * Returns a resource representing the stream. 21 * @param StreamInterface $stream The stream to get a resource for 24 * @throws \InvalidArgumentException if stream is not readable or writable 26 public static function getResource(StreamInterface $stream) argument 30 if ($stream->isReadable()) { 31 $mode = $stream->isWritable() ? 'r+' : 'r'; 32 } elseif ($stream [all...] |
H A D | InflateStream.php | 7 * This stream decorator skips the first 10 bytes of the given stream to remove 8 * the gzip header, converts the provided stream to a PHP stream resource, 9 * then appends the zlib.inflate filter. The stream is then converted back 10 * to a Guzzle stream resource to be used as a Guzzle stream. 19 public function __construct(StreamInterface $stream) argument 22 $stream = new LimitStream($stream, [all...] |
H A D | LimitStream.php | 7 * Decorator used to return only a subset of a stream 20 * @param StreamInterface $stream Stream to wrap 22 * from the stream. Pass -1 for no limit. 27 StreamInterface $stream, argument 31 $this->stream = $stream; 38 // Always return true if the underlying stream is EOF 39 if ($this->stream->eof()) { 43 // No limit and the underlying stream is not at EOF 48 $tell = $this->stream [all...] |
H A D | NoSeekStream.php | 5 * Stream decorator that prevents a stream from being seeked 21 public function attach($stream) argument 23 $this->stream->attach($stream);
|
H A D | NullStream.php | 25 public function attach($stream) argument
|
H A D | PumpStream.php | 7 * Provides a read only stream that pumps data from a PHP callable. 34 * @param callable $source Source of the stream data. The callable MAY 40 * - metadata: Hash of metadata to use with stream. 41 * - size: Size of the stream, if known. 67 public function attach($stream) argument
|
H A D | Stream.php | 5 * PHP stream implementation 9 private $stream; variable in GuzzleHttp\\Stream\\Stream 17 /** @var array Hash of readable and writable stream types */ 34 * Create a new stream based on the input type. 50 $stream = fopen('php://temp', 'r+'); 52 fwrite($stream, $resource); 53 fseek($stream, 0); 55 return new self($stream, $options); 91 * - size: (int) If a read stream would otherwise have an indeterminate 95 * of the stream i 102 __construct($stream, $options = []) global() argument 161 attach($stream) global() argument [all...] |
H A D | StreamDecoratorTrait.php | 8 * @property StreamInterface stream 13 * @param StreamInterface $stream Stream to decorate 15 public function __construct(StreamInterface $stream) argument 17 $this->stream = $stream; 21 * Magic method used to create a new stream if streams are not added in 26 if ($name == 'stream') { 27 $this->stream = $this->createStream(); 28 return $this->stream; 62 $result = call_user_func_array(array($this->stream, 83 attach($stream) global() argument [all...] |
H A D | StreamInterface.php | 5 * Describes a stream instance. 10 * Attempts to seek to the beginning of the stream and reads all data into 11 * a string until the end of the stream is reached. 20 * Closes the stream and any underlying resources. 25 * Separates any underlying resources from the stream. 27 * After the underlying resource has been detached, the stream object is in 28 * an unusable state. If you wish to use a Stream object as a PHP stream 32 * @return resource|null Returns the underlying PHP stream resource or null 34 * stream resource. 39 * Replaces the underlying stream resourc 53 attach($stream) global() argument [all...] |
H A D | Utils.php | 13 * Safely opens a PHP stream resource using a filename. 48 * Copy the contents of a stream into a string until the given number of 51 * @param StreamInterface $stream Stream to read 53 * to read the entire stream. 56 public static function copyToString(StreamInterface $stream, $maxLen = -1) argument 61 while (!$stream->eof()) { 62 $buf = $stream->read(1048576); 72 while (!$stream->eof() && $len < $maxLen) { 73 $buf = $stream->read($maxLen - $len); 85 * Copy the contents of a stream int 132 hash(StreamInterface $stream, $algo, $rawOutput = false) global() argument 162 readline(StreamInterface $stream, $maxLength = null, $eol = PHP_EOL) global() argument [all...] |
/plugin/elasticsearch/vendor/ezimuel/guzzlestreams/src/Exception/ |
H A D | SeekException.php | 7 * Exception thrown when a seek fails on a stream. 11 private $stream; variable in GuzzleHttp\\Stream\\Exception\\SeekException 13 public function __construct(StreamInterface $stream, $pos = 0, $msg = '') argument 15 $this->stream = $stream; 16 $msg = $msg ?: 'Could not seek the stream to position ' . $pos; 25 return $this->stream;
|
/plugin/elasticsearch/vendor/ezimuel/guzzlestreams/tests/ |
H A D | AsyncReadStreamTest.php | 73 $this->assertSame($buffer, $a->stream);
|
H A D | DroppingStreamTest.php | 12 $stream = new BufferStream(); 13 $drop = new DroppingStream($stream, 5); 20 $this->assertEquals(5, $stream->getSize());
|
H A D | GuzzleStreamWrapperTest.php | 16 $stream = Stream::factory('foo'); 17 $handle = GuzzleStreamWrapper::getResource($stream); 59 $this->assertSame('foobar', (string) $stream); 65 $stream = $this->getMockBuilder('GuzzleHttp\Stream\StreamInterface') 67 $stream->expects($this->once()) 70 $stream->expects($this->once()) 73 GuzzleStreamWrapper::getResource($stream); 85 $stream = $this->getMockBuilder('GuzzleHttp\Stream\StreamInterface') 87 $stream->expects($this->once()) 90 $stream [all...] |
H A D | StreamDecoratorTraitTest.php | 135 $s->stream;
|
H A D | StreamTest.php | 23 $stream = new Stream($handle); 24 $this->assertTrue($stream->isReadable()); 25 $this->assertTrue($stream->isWritable()); 26 $this->assertTrue($stream->isSeekable()); 27 $this->assertEquals('php://temp', $stream->getMetadata('uri')); 28 $this->assertIsArray($stream->getMetadata()); 29 $this->assertEquals(4, $stream->getSize()); 30 $this->assertFalse($stream->eof()); 31 $stream->close(); 37 $stream [all...] |
/plugin/elasticsearch/vendor/ezimuel/ringphp/ |
H A D | CHANGELOG.md | 49 - The PHP stream wrapper handler now sets `allow_self_signed` to `false` to 83 - Adding more error information to PHP stream wrapper exceptions. 103 - Setting the `header` stream option as a string to be compatible with GAE.
|
/plugin/elasticsearch/vendor/ezimuel/ringphp/src/Client/ |
H A D | StreamHandler.php | 14 * RingPHP client handler that uses PHP's HTTP stream wrapper. 34 $stream = $this->createStream($url, $request); 35 return $this->createResponse($request, $url, $stream); 41 private function createResponse(array $request, $url, $stream) argument 54 $stream = $this->checkDecode($request, $response, $stream); 56 // If not streaming, then drain the response into a stream. 57 if (empty($request['client']['stream'])) { 61 $stream = $this->drain($stream, 69 checkDecode(array $request, array $response, $stream) global() argument 93 drain($stream, $dest) global() argument [all...] |
/plugin/farm/install/animaltemplate/conf/ |
H A D | mime.conf | 7 tgz application/octet-stream 9 gz application/octet-stream 10 bz2 application/octet-stream 21 rpm application/octet-stream 22 deb application/octet-stream
|