Lines Matching refs:reader
7977 var reader = AcquireReadableStreamDefaultReader(this);
7990 return ReadableStreamDefaultReaderRead(reader).then(function (_ref5) {
8003 isOrBecomesErrored(_this, reader._closedPromise, function (storedError) {
8021 isOrBecomesClosed(_this, reader._closedPromise, function () {
8111 ReadableStreamReaderGenericRelease(reader);
8192 var reader = AcquireReadableStreamDefaultReader(stream);
8204 pull._reader = reader;
8224 reader._closedPromise["catch"](function (r) {
8239 var reader = f._reader,
8243 return ReadableStreamDefaultReaderRead(reader).then(function (result) {
8372 var reader = stream._reader;
8374 if (reader === undefined) {
8378 if (IsReadableStreamDefaultReader(reader) === true) {
8379 for (var i = 0; i < reader._readRequests.length; i++) {
8380 var _resolve = reader._readRequests[i]._resolve;
8385 reader._readRequests = [];
8388 defaultReaderClosedPromiseResolve(reader);
8397 var reader = stream._reader;
8399 if (reader === undefined) {
8403 if (IsReadableStreamDefaultReader(reader) === true) {
8404 for (var i = 0; i < reader._readRequests.length; i++) {
8405 var readRequest = reader._readRequests[i];
8410 reader._readRequests = [];
8412 assert(IsReadableStreamBYOBReader(reader), 'reader must be ReadableStreamBYOBReader');
8414 for (var _i = 0; _i < reader._readIntoRequests.length; _i++) {
8415 var readIntoRequest = reader._readIntoRequests[_i];
8420 reader._readIntoRequests = [];
8423 defaultReaderClosedPromiseReject(reader, e);
8425 reader._closedPromise["catch"](function () {});
8429 var reader = stream._reader;
8430 assert(reader._readIntoRequests.length > 0);
8432 var readIntoRequest = reader._readIntoRequests.shift();
8438 var reader = stream._reader;
8439 assert(reader._readRequests.length > 0);
8441 var readRequest = reader._readRequests.shift();
8455 var reader = stream._reader;
8457 if (reader === undefined) {
8461 if (IsReadableStreamBYOBReader(reader) === false) {
8469 var reader = stream._reader;
8471 if (reader === undefined) {
8475 if (IsReadableStreamDefaultReader(reader) === false) {
8664 function ReadableStreamReaderGenericInitialize(reader, stream) {
8665 reader._ownerReadableStream = stream;
8666 stream._reader = reader;
8669 defaultReaderClosedPromiseInitialize(reader);
8671 defaultReaderClosedPromiseInitializeAsResolved(reader);
8674 defaultReaderClosedPromiseInitializeAsRejected(reader, stream._storedError);
8676 reader._closedPromise["catch"](function () {});
8680 function ReadableStreamReaderGenericCancel(reader, reason) {
8681 var stream = reader._ownerReadableStream;
8686 function ReadableStreamReaderGenericRelease(reader) {
8687 assert(reader._ownerReadableStream !== undefined);
8688 assert(reader._ownerReadableStream._reader === reader);
8690 if (reader._ownerReadableStream._state === 'readable') {
8691 …defaultReaderClosedPromiseReject(reader, new TypeError('Reader was released and can no longer be u…
8693 …defaultReaderClosedPromiseResetToRejected(reader, new TypeError('Reader was released and can no lo…
8696 reader._closedPromise["catch"](function () {});
8698 reader._ownerReadableStream._reader = undefined;
8699 reader._ownerReadableStream = undefined;
8702 function ReadableStreamBYOBReaderRead(reader, view) {
8703 var stream = reader._ownerReadableStream;
8714 function ReadableStreamDefaultReaderRead(reader) {
8715 var stream = reader._ownerReadableStream;
9686 function defaultReaderClosedPromiseInitialize(reader) {
9687 reader._closedPromise = new Promise(function (resolve, reject) {
9688 reader._closedPromise_resolve = resolve;
9689 reader._closedPromise_reject = reject;
9693 function defaultReaderClosedPromiseInitializeAsRejected(reader, reason) {
9694 reader._closedPromise = Promise.reject(reason);
9695 reader._closedPromise_resolve = undefined;
9696 reader._closedPromise_reject = undefined;
9699 function defaultReaderClosedPromiseInitializeAsResolved(reader) {
9700 reader._closedPromise = Promise.resolve(undefined);
9701 reader._closedPromise_resolve = undefined;
9702 reader._closedPromise_reject = undefined;
9705 function defaultReaderClosedPromiseReject(reader, reason) {
9706 assert(reader._closedPromise_resolve !== undefined);
9707 assert(reader._closedPromise_reject !== undefined);
9709 reader._closedPromise_reject(reason);
9711 reader._closedPromise_resolve = undefined;
9712 reader._closedPromise_reject = undefined;
9715 function defaultReaderClosedPromiseResetToRejected(reader, reason) {
9716 assert(reader._closedPromise_resolve === undefined);
9717 assert(reader._closedPromise_reject === undefined);
9718 reader._closedPromise = Promise.reject(reason);
9721 function defaultReaderClosedPromiseResolve(reader) {
9722 assert(reader._closedPromise_resolve !== undefined);
9723 assert(reader._closedPromise_reject !== undefined);
9725 reader._closedPromise_resolve(undefined);
9727 reader._closedPromise_resolve = undefined;
9728 reader._closedPromise_reject = undefined;
20884 decodeNode: function decodeNode(reader) {
20890 var htOffset = reader.readBits(this.rangeLength);
20894 var node = this.children[reader.readBit()];
20900 return node.decodeNode(reader);
20924 decode: function decode(reader) {
20925 return this.rootNode.decodeNode(reader);
20974 var reader = new Reader(data, start + 9, end);
20983 prefixLength = reader.readBits(prefixSizeBits);
20984 rangeLength = reader.readBits(rangeSizeBits);
20989 prefixLength = reader.readBits(prefixSizeBits);
20991 prefixLength = reader.readBits(prefixSizeBits);
20995 prefixLength = reader.readBits(prefixSizeBits);
21157 …function getTextRegionHuffmanTables(textRegion, referredTo, customTables, numberOfSymbols, reader)…
21163 codeLength = reader.readBits(4);
21171 codeLength = runCodesTable.decode(reader);
21184 numberOfRepeats = reader.readBits(2) + 3;
21189 numberOfRepeats = reader.readBits(3) + 3;
21194 numberOfRepeats = reader.readBits(7) + 11;
21212 reader.byteAlign();
21336 function readUncompressedBitmap(reader, width, height) {
21347 row[x] = reader.readBit();
21350 reader.byteAlign();
49008 function decodeType4Shading(mesh, reader) {
49015 while (reader.hasData) {
49016 var f = reader.readFlag();
49017 var coord = reader.readCoordinate();
49018 var color = reader.readComponents();
49048 reader.align();
49058 function decodeType5Shading(mesh, reader, verticesPerRow) {
49063 while (reader.hasData) {
49064 var coord = reader.readCoordinate();
49065 var color = reader.readComponents();
49186 function decodeType6Shading(mesh, reader) {
49192 while (reader.hasData) {
49193 var f = reader.readFlag();
49203 coords.push(reader.readCoordinate());
49209 colors.push(reader.readComponents());
49317 function decodeType7Shading(mesh, reader) {
49323 while (reader.hasData) {
49324 var f = reader.readFlag();
49334 coords.push(reader.readCoordinate());
49340 colors.push(reader.readComponents());
49539 var reader = new MeshStreamReader(stream, decodeContext);
49544 decodeType4Shading(this, reader);
49554 decodeType5Shading(this, reader, verticesPerRow);
49558 decodeType6Shading(this, reader);
49563 decodeType7Shading(this, reader);
55984 var reader = new PDFWorkerStreamRangeReader(begin, end, this._msgHandler);
55986 this._rangeRequestReaders.push(reader);
55988 return reader;
55999 readers.forEach(function (reader) {
56000 reader.cancel(reason);