Lines Matching refs:writer
5776 var writer = stream._writer;
5778 if (writer !== undefined) {
5779 WritableStreamDefaultWriterEnsureReadyPromiseRejected(writer, reason);
5870 var writer = stream._writer;
5872 if (writer !== undefined) {
5873 defaultWriterClosedPromiseResolve(writer);
5937 var writer = stream._writer;
5939 if (writer !== undefined) {
5940 defaultWriterClosedPromiseReject(writer, stream._storedError);
5942 writer._closedPromise["catch"](function () {});
5949 var writer = stream._writer;
5951 if (writer !== undefined && backpressure !== stream._backpressure) {
5953 defaultWriterReadyPromiseReset(writer);
5956 defaultWriterReadyPromiseResolve(writer);
6118 function WritableStreamDefaultWriterAbort(writer, reason) {
6119 var stream = writer._ownerWritableStream;
6124 function WritableStreamDefaultWriterClose(writer) {
6125 var stream = writer._ownerWritableStream;
6144 defaultWriterReadyPromiseResolve(writer);
6151 function WritableStreamDefaultWriterCloseWithErrorPropagation(writer) {
6152 var stream = writer._ownerWritableStream;
6165 return WritableStreamDefaultWriterClose(writer);
6168 function WritableStreamDefaultWriterEnsureClosedPromiseRejected(writer, error) {
6169 if (writer._closedPromiseState === 'pending') {
6170 defaultWriterClosedPromiseReject(writer, error);
6172 defaultWriterClosedPromiseResetToRejected(writer, error);
6175 writer._closedPromise["catch"](function () {});
6178 function WritableStreamDefaultWriterEnsureReadyPromiseRejected(writer, error) {
6179 if (writer._readyPromiseState === 'pending') {
6180 defaultWriterReadyPromiseReject(writer, error);
6182 defaultWriterReadyPromiseResetToRejected(writer, error);
6185 writer._readyPromise["catch"](function () {});
6188 function WritableStreamDefaultWriterGetDesiredSize(writer) {
6189 var stream = writer._ownerWritableStream;
6203 function WritableStreamDefaultWriterRelease(writer) {
6204 var stream = writer._ownerWritableStream;
6206 assert(stream._writer === writer);
6208 WritableStreamDefaultWriterEnsureReadyPromiseRejected(writer, releasedError);
6209 WritableStreamDefaultWriterEnsureClosedPromiseRejected(writer, releasedError);
6211 writer._ownerWritableStream = undefined;
6214 function WritableStreamDefaultWriterWrite(writer, chunk) {
6215 var stream = writer._ownerWritableStream;
6220 if (stream !== writer._ownerWritableStream) {
6472 function defaultWriterClosedPromiseInitialize(writer) {
6473 writer._closedPromise = new Promise(function (resolve, reject) {
6474 writer._closedPromise_resolve = resolve;
6475 writer._closedPromise_reject = reject;
6476 writer._closedPromiseState = 'pending';
6480 function defaultWriterClosedPromiseInitializeAsRejected(writer, reason) {
6481 writer._closedPromise = Promise.reject(reason);
6482 writer._closedPromise_resolve = undefined;
6483 writer._closedPromise_reject = undefined;
6484 writer._closedPromiseState = 'rejected';
6487 function defaultWriterClosedPromiseInitializeAsResolved(writer) {
6488 writer._closedPromise = Promise.resolve(undefined);
6489 writer._closedPromise_resolve = undefined;
6490 writer._closedPromise_reject = undefined;
6491 writer._closedPromiseState = 'resolved';
6494 function defaultWriterClosedPromiseReject(writer, reason) {
6495 …assert(writer._closedPromise_resolve !== undefined, 'writer._closedPromise_resolve !== undefined');
6496 … assert(writer._closedPromise_reject !== undefined, 'writer._closedPromise_reject !== undefined');
6497 assert(writer._closedPromiseState === 'pending', 'writer._closedPromiseState is pending');
6499 writer._closedPromise_reject(reason);
6501 writer._closedPromise_resolve = undefined;
6502 writer._closedPromise_reject = undefined;
6503 writer._closedPromiseState = 'rejected';
6506 function defaultWriterClosedPromiseResetToRejected(writer, reason) {
6507 …assert(writer._closedPromise_resolve === undefined, 'writer._closedPromise_resolve === undefined');
6508 … assert(writer._closedPromise_reject === undefined, 'writer._closedPromise_reject === undefined');
6509 assert(writer._closedPromiseState !== 'pending', 'writer._closedPromiseState is not pending');
6510 writer._closedPromise = Promise.reject(reason);
6511 writer._closedPromiseState = 'rejected';
6514 function defaultWriterClosedPromiseResolve(writer) {
6515 …assert(writer._closedPromise_resolve !== undefined, 'writer._closedPromise_resolve !== undefined');
6516 … assert(writer._closedPromise_reject !== undefined, 'writer._closedPromise_reject !== undefined');
6517 assert(writer._closedPromiseState === 'pending', 'writer._closedPromiseState is pending');
6519 writer._closedPromise_resolve(undefined);
6521 writer._closedPromise_resolve = undefined;
6522 writer._closedPromise_reject = undefined;
6523 writer._closedPromiseState = 'resolved';
6526 function defaultWriterReadyPromiseInitialize(writer) {
6527 writer._readyPromise = new Promise(function (resolve, reject) {
6528 writer._readyPromise_resolve = resolve;
6529 writer._readyPromise_reject = reject;
6531 writer._readyPromiseState = 'pending';
6534 function defaultWriterReadyPromiseInitializeAsRejected(writer, reason) {
6535 writer._readyPromise = Promise.reject(reason);
6536 writer._readyPromise_resolve = undefined;
6537 writer._readyPromise_reject = undefined;
6538 writer._readyPromiseState = 'rejected';
6541 function defaultWriterReadyPromiseInitializeAsResolved(writer) {
6542 writer._readyPromise = Promise.resolve(undefined);
6543 writer._readyPromise_resolve = undefined;
6544 writer._readyPromise_reject = undefined;
6545 writer._readyPromiseState = 'fulfilled';
6548 function defaultWriterReadyPromiseReject(writer, reason) {
6549 … assert(writer._readyPromise_resolve !== undefined, 'writer._readyPromise_resolve !== undefined');
6550 assert(writer._readyPromise_reject !== undefined, 'writer._readyPromise_reject !== undefined');
6552 writer._readyPromise_reject(reason);
6554 writer._readyPromise_resolve = undefined;
6555 writer._readyPromise_reject = undefined;
6556 writer._readyPromiseState = 'rejected';
6559 function defaultWriterReadyPromiseReset(writer) {
6560 … assert(writer._readyPromise_resolve === undefined, 'writer._readyPromise_resolve === undefined');
6561 assert(writer._readyPromise_reject === undefined, 'writer._readyPromise_reject === undefined');
6562 writer._readyPromise = new Promise(function (resolve, reject) {
6563 writer._readyPromise_resolve = resolve;
6564 writer._readyPromise_reject = reject;
6566 writer._readyPromiseState = 'pending';
6569 function defaultWriterReadyPromiseResetToRejected(writer, reason) {
6570 … assert(writer._readyPromise_resolve === undefined, 'writer._readyPromise_resolve === undefined');
6571 assert(writer._readyPromise_reject === undefined, 'writer._readyPromise_reject === undefined');
6572 writer._readyPromise = Promise.reject(reason);
6573 writer._readyPromiseState = 'rejected';
6576 function defaultWriterReadyPromiseResolve(writer) {
6577 … assert(writer._readyPromise_resolve !== undefined, 'writer._readyPromise_resolve !== undefined');
6578 assert(writer._readyPromise_reject !== undefined, 'writer._readyPromise_reject !== undefined');
6580 writer._readyPromise_resolve(undefined);
6582 writer._readyPromise_resolve = undefined;
6583 writer._readyPromise_reject = undefined;
6584 writer._readyPromiseState = 'fulfilled';
6809 var writer = AcquireWritableStreamDefaultWriter(dest);
6820 return writer._readyPromise.then(function () {
6829 … currentWrite = WritableStreamDefaultWriterWrite(writer, value)["catch"](function () {});
6843 isOrBecomesErrored(dest, writer._closedPromise, function (storedError) {
6855 return WritableStreamDefaultWriterCloseWithErrorPropagation(writer);
6941 WritableStreamDefaultWriterRelease(writer);