Lines Matching refs:stream
6 const { Readable } = require('stream')
41 // Is stream being consumed through Readable API?
147 this[kBody].getReader() // Ensure stream is locked.
212 async function consume (stream, type) {
213 if (isUnusable(stream)) {
217 assert(!stream[kConsume])
220 stream[kConsume] = {
222 stream,
229 stream
239 process.nextTick(consumeStart, stream[kConsume])
248 const { _readableState: state } = consume.stream
257 consume.stream.on('end', function () {
262 consume.stream.resume()
264 while (consume.stream.read() != null) {
270 const { type, body, resolve, stream, length } = consume
291 resolve(new Blob(body, { type: stream[kContentType] }))
296 stream.destroy(err)
317 consume.stream = null