Lines Matching refs:buffer
61 * @param StreamInterface $buffer Buffer that contains the data that has
69 StreamInterface $buffer, argument
72 if (!$buffer->isReadable() || !$buffer->isWritable()) {
94 $this->hwm = $buffer->getMetadata('hwm');
101 $this->stream = $buffer;
139 $buffer = new NullStream();
141 $buffer = $options['buffer'];
144 $buffer = new BufferStream($hwm);
148 $buffer = new DroppingStream($buffer, $options['max_buffer']);
154 $buffer = FnStream::decorate($buffer, [
155 'write' => function ($string) use ($buffer, $onWrite) {
156 $result = $buffer->write($string);
157 $onWrite($buffer, $string);
163 return [$buffer, new self($buffer, $options)];