Lines Matching refs:stream
17037 var PDFDocument, PDFObject, PDFPage, PDFReference, fs, stream,
17041 stream = __webpack_require__(25);
17268 })(stream.Readable);
17826 function ReadableState(options, stream) {
17866 if (stream instanceof Duplex)
17932 function readableAddChunk(stream, state, chunk, encoding, addToFront) {
17935 stream.emit('error', er);
17939 onEofChunk(stream, state);
17943 stream.emit('error', e);
17946 stream.emit('error', e);
17956 stream.emit('data', chunk);
17957 stream.read(0);
17967 emitReadable(stream);
17970 maybeReadMore(stream, state);
18183 function onEofChunk(stream, state) {
18194 emitReadable(stream);
18200 function emitReadable(stream) {
18201 var state = stream._readableState;
18208 emitReadable_(stream);
18211 emitReadable_(stream);
18215 function emitReadable_(stream) {
18217 stream.emit('readable');
18218 flow(stream);
18228 function maybeReadMore(stream, state) {
18232 maybeReadMore_(stream, state);
18237 function maybeReadMore_(stream, state) {
18242 stream.read(0);
18510 function resume(stream, state) {
18514 resume_(stream, state);
18519 function resume_(stream, state) {
18521 stream.emit('resume');
18522 flow(stream);
18524 stream.read(0);
18537 function flow(stream) {
18538 var state = stream._readableState;
18542 var chunk = stream.read();
18550 Readable.prototype.wrap = function(stream) {
18555 stream.on('end', function() {
18566 stream.on('data', function(chunk) {
18576 stream.pause();
18582 for (var i in stream) {
18583 if (util.isFunction(stream[i]) && util.isUndefined(this[i])) {
18585 return stream[method].apply(stream, arguments);
18593 stream.on(ev, self.emit.bind(self, ev));
18602 stream.resume();
18680 function endReadable(stream) {
18681 var state = stream._readableState;
18694 stream.readable = false;
18695 stream.emit('end');
19118 function WritableState(options, stream) {
19134 if (stream instanceof Duplex)
19183 onwrite(stream, er);
19228 function writeAfterEnd(stream, state, cb) {
19231 stream.emit('error', er);
19242 function validChunk(stream, state, chunk, cb) {
19249 stream.emit('error', er);
19318 function writeOrBuffer(stream, state, chunk, encoding, cb) {
19334 doWrite(stream, state, false, len, chunk, encoding, cb);
19339 function doWrite(stream, state, writev, len, chunk, encoding, cb) {
19345 stream._writev(chunk, state.onwrite);
19347 stream._write(chunk, encoding, state.onwrite);
19351 function onwriteError(stream, state, sync, er, cb) {
19362 stream._writableState.errorEmitted = true;
19363 stream.emit('error', er);
19373 function onwrite(stream, er) {
19374 var state = stream._writableState;
19381 onwriteError(stream, state, sync, er, cb);
19384 var finished = needFinish(stream, state);
19390 clearBuffer(stream, state);
19395 afterWrite(stream, state, finished, cb);
19398 afterWrite(stream, state, finished, cb);
19403 function afterWrite(stream, state, finished, cb) {
19405 onwriteDrain(stream, state);
19408 finishMaybe(stream, state);
19414 function onwriteDrain(stream, state) {
19417 stream.emit('drain');
19423 function clearBuffer(stream, state) {
19426 if (stream._writev && state.buffer.length > 1) {
19435 doWrite(stream, state, true, state.length, state.buffer, '', function(err) {
19453 doWrite(stream, state, false, len, chunk, encoding, cb);
19508 function needFinish(stream, state) {
19515 function prefinish(stream, state) {
19518 stream.emit('prefinish');
19522 function finishMaybe(stream, state) {
19523 var need = needFinish(stream, state);
19526 prefinish(stream, state);
19528 stream.emit('finish');
19530 prefinish(stream, state);
19535 function endWritable(stream, state, cb) {
19537 finishMaybe(stream, state);
19542 stream.once('finish', cb);
19856 function TransformState(options, stream) {
19858 return afterTransform(stream, er, data);
19867 function afterTransform(stream, er, data) {
19868 var ts = stream._transformState;
19874 return stream.emit('error', new Error('no writecb in Transform class'));
19880 stream.push(data);
19885 var rs = stream._readableState;
19888 stream._read(rs.highWaterMark);
19902 var stream = this;
19915 done(stream, er);
19918 done(stream);
19972 function done(stream, er) {
19974 return stream.emit('error', er);
19978 var ws = stream._writableState;
19979 var ts = stream._transformState;
19987 return stream.push(null);