Lines Matching refs:reader
6808 var reader = AcquireReadableStreamDefaultReader(this);
6821 return ReadableStreamDefaultReaderRead(reader).then(function (_ref5) {
6834 isOrBecomesErrored(_this, reader._closedPromise, function (storedError) {
6852 isOrBecomesClosed(_this, reader._closedPromise, function () {
6942 ReadableStreamReaderGenericRelease(reader);
7023 var reader = AcquireReadableStreamDefaultReader(stream);
7035 pull._reader = reader;
7055 reader._closedPromise["catch"](function (r) {
7070 var reader = f._reader,
7074 return ReadableStreamDefaultReaderRead(reader).then(function (result) {
7203 var reader = stream._reader;
7205 if (reader === undefined) {
7209 if (IsReadableStreamDefaultReader(reader) === true) {
7210 for (var i = 0; i < reader._readRequests.length; i++) {
7211 var _resolve = reader._readRequests[i]._resolve;
7216 reader._readRequests = [];
7219 defaultReaderClosedPromiseResolve(reader);
7228 var reader = stream._reader;
7230 if (reader === undefined) {
7234 if (IsReadableStreamDefaultReader(reader) === true) {
7235 for (var i = 0; i < reader._readRequests.length; i++) {
7236 var readRequest = reader._readRequests[i];
7241 reader._readRequests = [];
7243 assert(IsReadableStreamBYOBReader(reader), 'reader must be ReadableStreamBYOBReader');
7245 for (var _i = 0; _i < reader._readIntoRequests.length; _i++) {
7246 var readIntoRequest = reader._readIntoRequests[_i];
7251 reader._readIntoRequests = [];
7254 defaultReaderClosedPromiseReject(reader, e);
7256 reader._closedPromise["catch"](function () {});
7260 var reader = stream._reader;
7261 assert(reader._readIntoRequests.length > 0);
7263 var readIntoRequest = reader._readIntoRequests.shift();
7269 var reader = stream._reader;
7270 assert(reader._readRequests.length > 0);
7272 var readRequest = reader._readRequests.shift();
7286 var reader = stream._reader;
7288 if (reader === undefined) {
7292 if (IsReadableStreamBYOBReader(reader) === false) {
7300 var reader = stream._reader;
7302 if (reader === undefined) {
7306 if (IsReadableStreamDefaultReader(reader) === false) {
7495 function ReadableStreamReaderGenericInitialize(reader, stream) {
7496 reader._ownerReadableStream = stream;
7497 stream._reader = reader;
7500 defaultReaderClosedPromiseInitialize(reader);
7502 defaultReaderClosedPromiseInitializeAsResolved(reader);
7505 defaultReaderClosedPromiseInitializeAsRejected(reader, stream._storedError);
7507 reader._closedPromise["catch"](function () {});
7511 function ReadableStreamReaderGenericCancel(reader, reason) {
7512 var stream = reader._ownerReadableStream;
7517 function ReadableStreamReaderGenericRelease(reader) {
7518 assert(reader._ownerReadableStream !== undefined);
7519 assert(reader._ownerReadableStream._reader === reader);
7521 if (reader._ownerReadableStream._state === 'readable') {
7522 …defaultReaderClosedPromiseReject(reader, new TypeError('Reader was released and can no longer be u…
7524 …defaultReaderClosedPromiseResetToRejected(reader, new TypeError('Reader was released and can no lo…
7527 reader._closedPromise["catch"](function () {});
7529 reader._ownerReadableStream._reader = undefined;
7530 reader._ownerReadableStream = undefined;
7533 function ReadableStreamBYOBReaderRead(reader, view) {
7534 var stream = reader._ownerReadableStream;
7545 function ReadableStreamDefaultReaderRead(reader) {
7546 var stream = reader._ownerReadableStream;
8517 function defaultReaderClosedPromiseInitialize(reader) {
8518 reader._closedPromise = new Promise(function (resolve, reject) {
8519 reader._closedPromise_resolve = resolve;
8520 reader._closedPromise_reject = reject;
8524 function defaultReaderClosedPromiseInitializeAsRejected(reader, reason) {
8525 reader._closedPromise = Promise.reject(reason);
8526 reader._closedPromise_resolve = undefined;
8527 reader._closedPromise_reject = undefined;
8530 function defaultReaderClosedPromiseInitializeAsResolved(reader) {
8531 reader._closedPromise = Promise.resolve(undefined);
8532 reader._closedPromise_resolve = undefined;
8533 reader._closedPromise_reject = undefined;
8536 function defaultReaderClosedPromiseReject(reader, reason) {
8537 assert(reader._closedPromise_resolve !== undefined);
8538 assert(reader._closedPromise_reject !== undefined);
8540 reader._closedPromise_reject(reason);
8542 reader._closedPromise_resolve = undefined;
8543 reader._closedPromise_reject = undefined;
8546 function defaultReaderClosedPromiseResetToRejected(reader, reason) {
8547 assert(reader._closedPromise_resolve === undefined);
8548 assert(reader._closedPromise_reject === undefined);
8549 reader._closedPromise = Promise.reject(reason);
8552 function defaultReaderClosedPromiseResolve(reader) {
8553 assert(reader._closedPromise_resolve !== undefined);
8554 assert(reader._closedPromise_reject !== undefined);
8556 reader._closedPromise_resolve(undefined);
8558 reader._closedPromise_resolve = undefined;
8559 reader._closedPromise_reject = undefined;
10698 reader.read().then(function (_ref5) {
10717 var reader = readableStream.getReader();
17971 value: function _removeRangeReader(reader) {
17972 var i = this._rangeReaders.indexOf(reader);
17993 var reader = new PDFDataTransportStreamRangeReader(this, begin, end);
17997 this._rangeReaders.push(reader);
17999 return reader;
22690 readers.forEach(function (reader) {
22691 reader.cancel(reason);
23780 value: function _onRangeRequestReaderClosed(reader) {
23781 var i = this._rangeRequestReaders.indexOf(reader);
23797 var reader = new PDFNetworkStreamRangeRequestReader(this._manager, begin, end);
23798 reader.onClosed = this._onRangeRequestReaderClosed.bind(this);
23800 this._rangeRequestReaders.push(reader);
23802 return reader;
23813 readers.forEach(function (reader) {
23814 reader.cancel(reason);
24279 var reader = new PDFFetchStreamRangeReader(this, begin, end);
24281 this._rangeRequestReaders.push(reader);
24283 return reader;
24294 readers.forEach(function (reader) {
24295 reader.cancel(reason);