Lines Matching defs:function
106 function makeBitMapDescriptor(bit) {
154 function ReadableState(options, stream, isDuplex) {
221 function Readable(options) {
232 if (typeof options.read === 'function')
235 if (typeof options.destroy === 'function')
238 if (typeof options.construct === 'function')
256 Readable.prototype._destroy = function(err, cb) {
260 Readable.prototype[EE.captureRejectionSymbol] = function(err) {
264 Readable.prototype[SymbolAsyncDispose] = function() {
277 Readable.prototype.push = function(chunk, encoding) {
282 Readable.prototype.unshift = function(chunk, encoding) {
286 function readableAddChunk(stream, chunk, encoding, addToFront) {
356 function addChunk(stream, state, chunk, addToFront) {
383 Readable.prototype.isPaused = function() {
389 Readable.prototype.setEncoding = function(enc) {
410 function computeNewHighWaterMark(n) {
427 // This function is designed to be inlinable, so please take care when making
428 // changes to the function body.
429 function howMuchToRead(n, state) {
446 Readable.prototype.read = function(n) {
588 function onEofChunk(stream, state) {
618 function emitReadable(stream) {
629 function emitReadable_(stream) {
657 function maybeReadMore(stream, state) {
664 function maybeReadMore_(stream, state) {
705 Readable.prototype._read = function(n) {
709 Readable.prototype.pipe = function(dest, pipeOpts) {
736 function onunpipe(readable, unpipeInfo) {
746 function onend() {
754 function cleanup() {
780 function pause() {
807 function ondata(chunk) {
818 function onerror(er) {
837 function onclose() {
842 function onfinish() {
849 function unpipe() {
869 function pipeOnDrain(src, dest) {
870 return function pipeOnDrainFunctionResult() {
892 Readable.prototype.unpipe = function(dest) {
927 Readable.prototype.on = function(ev, fn) {
957 Readable.prototype.removeListener = function(ev, fn) {
975 Readable.prototype.removeAllListeners = function(ev) {
992 function updateReadableListening(self) {
1009 function nReadingNextTick(self) {
1016 Readable.prototype.resume = function() {
1030 function resume(stream, state) {
1037 function resume_(stream, state) {
1050 Readable.prototype.pause = function() {
1061 function flow(stream) {
1070 Readable.prototype.wrap = function(stream) {
1111 if (this[i] === undefined && typeof stream[i] === 'function') {
1119 Readable.prototype[SymbolAsyncIterator] = function() {
1123 Readable.prototype.iterator = function(options) {
1130 function streamToAsyncIterator(stream, options) {
1131 if (typeof stream.read !== 'function') {
1140 async function* createAsyncIterator(stream, options) {
1143 function next(resolve) {
1216 get: function() {
1224 get: function() {
1236 get: function() {
1244 get: function() {
1252 get: function() {
1255 set: function(state) {
1356 // This function is designed to be inlinable, so please take care when making
1357 // changes to the function body.
1358 function fromList(n, state) {
1383 function endReadable(stream) {
1393 function endReadableNT(state, stream) {
1422 function endWritableNT(stream) {
1430 Readable.from = function(iterable, opts) {
1437 function lazyWebStreams() {
1443 Readable.fromWeb = function(readableStream, options) {
1449 Readable.toWeb = function(streamReadable, options) {
1455 Readable.wrap = function(src, options) {