Home
last modified time | relevance | path

Searched refs:stream (Results 51 – 75 of 459) sorted by last modified time

12345678910>>...19

/plugin/elasticsearch/vendor/ezimuel/guzzlestreams/src/
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 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...]
/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 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...]
/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/elasticsearch/elasticsearch/docs/build/Elasticsearch/Namespaces/
H A DIndicesNamespace.asciidoc189 $params['name'] = (string) The name of the data stream
202 $params['name'] = (list) A comma-separated list of data stream names; use `_all` or empty string to perform the operation on all data streams
637 $params['name'] = (string) The name of the data stream
/plugin/html5video2/script/
H A Dvideo.min.js23 …stream"}):l({message:"programDateTime tags must be provided in the manifest "+i.resolvedUri}):l({m…
27 …urn ir.log.warn("We received no playlist to switch to. Please check your stream."),!1;var l="allow…
/plugin/davcal/vendor/sabre/http/lib/
H A DMessage.php51 $stream = fopen('php://temp', 'r+');
52 fwrite($stream, $body);
53 rewind($stream);
54 return $stream;
/plugin/davcal/vendor/sabre/vobject/tests/VObject/Parser/
H A DJsonTest.php368 $stream = fopen('php://memory','r+');
369 fwrite($stream, json_encode($input));
370 rewind($stream);
372 $result = VObject\Reader::readJson($stream,0);
/plugin/davcal/vendor/sabre/vobject/tests/VObject/
H A DReaderTest.php22 $stream = fopen('php://memory', 'r+');
23 fwrite($stream, $data);
24 rewind($stream);
26 $result = Reader::read($stream);
/plugin/davcal/vendor/sabre/vobject/tests/VObject/Splitter/
H A DICalendarTest.php17 $stream = fopen('php://memory','r+');
18 fwrite($stream, $data);
19 rewind($stream);
20 return $stream;
/plugin/davcal/vendor/sabre/vobject/lib/Parser/
H A DMimeDir.php83 $stream = fopen('php://temp', 'r+');
84 fwrite($stream, $input);
85 rewind($stream);
86 $this->input = $stream;
/plugin/davcal/
H A Dics.php48 $stream = $hlp->getCalendarAsICSFeed($calid); variable
52 echo $stream;
/plugin/davcal/vendor/sabre/xml/tests/Sabre/Xml/
H A DServiceTest.php76 $stream = fopen('php://memory', 'r+');
77 fwrite($stream, $xml);
78 rewind($stream);
81 $result = $util->parse($stream, null, $rootElement);
137 $stream = fopen('php://memory', 'r+');
138 fwrite($stream, $xml);
139 rewind($stream);
142 $result = $util->expect('{http://sabre.io/ns}root', $stream);
/plugin/davcal/vendor/sabre/dav/lib/DAV/
H A DTree.php307 $stream = fopen('php://temp', 'r+');
308 fwrite($stream, $data);
309 rewind($stream);
310 $data = $stream;
/plugin/davcal/vendor/sabre/dav/tests/Sabre/CalDAV/
H A DCalendarObjectTest.php99 $stream = fopen('php://temp','r+');
100 fwrite($stream, $newData);
101 rewind($stream);
102 $children[0]->put($stream);
/plugin/davcal/vendor/sabre/dav/tests/Sabre/CalDAV/Schedule/
H A DScheduleDeliverTest.php567 $stream = fopen('php://memory','r+');
568 fwrite($stream, $newObject);
569 rewind($stream);
575 &$stream,
579 $newObject = $stream;
592 $stream = fopen('php://memory','r+');
593 fwrite($stream, $newObject);
594 rewind($stream);
598 &$stream,
604 $newObject = $stream;
/plugin/davcal/vendor/sabre/dav/tests/Sabre/DAV/FSExt/
H A DFileTest.php54 $stream = fopen('php://memory','r+');
55 fwrite($stream, "222");
56 rewind($stream);
60 $file->patch($stream, 2, 3);
/plugin/davcal/vendor/sabre/dav/tests/Sabre/DAV/Mock/
H A DStreamingFile.php42 $stream = fopen('php://memory','r+');
43 fwrite($stream, $data);
44 rewind($stream);
45 $data = $stream;
/plugin/davcal/vendor/sabre/http/
H A DREADME.md473 * Returns the body as a readable stream resource.
475 * Note that the stream may not be rewindable, and therefore may only be
485 * Note that because the underlying data may be based on a stream, this
495 * This could be either a string or a stream.
502 * Updates the body resource with a new stream.
617 * Returns the body as a readable stream resource.
619 * Note that the stream may not be rewindable, and therefore may only be
629 * Note that because the underlying data may be based on a stream, this
639 * This could be either a string or a stream.
647 * Updates the body resource with a new stream.

12345678910>>...19