Home
last modified time | relevance | path

Searched refs:stream (Results 251 – 275 of 459) sorted by path

1...<<111213141516171819

/plugin/elasticsearch/vendor/ezimuel/guzzlestreams/src/
H A DAppendStream.php9 * 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 DAsyncReadStream.php5 * 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 DBufferStream.php7 * 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 DCachingStream.php8 * 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 DDroppingStream.php6 * 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 DFnStream.php5 * 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 DGuzzleStreamWrapper.php5 * 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 DInflateStream.php7 * 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 DLimitStream.php7 * 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 DNoSeekStream.php5 * Stream decorator that prevents a stream from being seeked
21 public function attach($stream) argument
23 $this->stream->attach($stream);
H A DNullStream.php25 public function attach($stream) argument
H A DPumpStream.php7 * 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 DStream.php5 * 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 DStreamDecoratorTrait.php8 * @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 DStreamInterface.php5 * 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 DUtils.php13 * 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 DSeekException.php7 * 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 DAsyncReadStreamTest.php73 $this->assertSame($buffer, $a->stream);
H A DDroppingStreamTest.php12 $stream = new BufferStream();
13 $drop = new DroppingStream($stream, 5);
20 $this->assertEquals(5, $stream->getSize());
H A DGuzzleStreamWrapperTest.php16 $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 DStreamDecoratorTraitTest.php135 $s->stream;
H A DStreamTest.php23 $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 DCHANGELOG.md49 - 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 DStreamHandler.php14 * 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 Dmime.conf7 tgz application/octet-stream
9 gz application/octet-stream
10 bz2 application/octet-stream
21 rpm application/octet-stream
22 deb application/octet-stream

1...<<111213141516171819