Lines Matching refs:writer
6945 var writer = stream._writer;
6947 if (writer !== undefined) {
6948 WritableStreamDefaultWriterEnsureReadyPromiseRejected(writer, reason);
7039 var writer = stream._writer;
7041 if (writer !== undefined) {
7042 defaultWriterClosedPromiseResolve(writer);
7106 var writer = stream._writer;
7108 if (writer !== undefined) {
7109 defaultWriterClosedPromiseReject(writer, stream._storedError);
7111 writer._closedPromise["catch"](function () {});
7118 var writer = stream._writer;
7120 if (writer !== undefined && backpressure !== stream._backpressure) {
7122 defaultWriterReadyPromiseReset(writer);
7125 defaultWriterReadyPromiseResolve(writer);
7287 function WritableStreamDefaultWriterAbort(writer, reason) {
7288 var stream = writer._ownerWritableStream;
7293 function WritableStreamDefaultWriterClose(writer) {
7294 var stream = writer._ownerWritableStream;
7313 defaultWriterReadyPromiseResolve(writer);
7320 function WritableStreamDefaultWriterCloseWithErrorPropagation(writer) {
7321 var stream = writer._ownerWritableStream;
7334 return WritableStreamDefaultWriterClose(writer);
7337 function WritableStreamDefaultWriterEnsureClosedPromiseRejected(writer, error) {
7338 if (writer._closedPromiseState === 'pending') {
7339 defaultWriterClosedPromiseReject(writer, error);
7341 defaultWriterClosedPromiseResetToRejected(writer, error);
7344 writer._closedPromise["catch"](function () {});
7347 function WritableStreamDefaultWriterEnsureReadyPromiseRejected(writer, error) {
7348 if (writer._readyPromiseState === 'pending') {
7349 defaultWriterReadyPromiseReject(writer, error);
7351 defaultWriterReadyPromiseResetToRejected(writer, error);
7354 writer._readyPromise["catch"](function () {});
7357 function WritableStreamDefaultWriterGetDesiredSize(writer) {
7358 var stream = writer._ownerWritableStream;
7372 function WritableStreamDefaultWriterRelease(writer) {
7373 var stream = writer._ownerWritableStream;
7375 assert(stream._writer === writer);
7377 WritableStreamDefaultWriterEnsureReadyPromiseRejected(writer, releasedError);
7378 WritableStreamDefaultWriterEnsureClosedPromiseRejected(writer, releasedError);
7380 writer._ownerWritableStream = undefined;
7383 function WritableStreamDefaultWriterWrite(writer, chunk) {
7384 var stream = writer._ownerWritableStream;
7389 if (stream !== writer._ownerWritableStream) {
7641 function defaultWriterClosedPromiseInitialize(writer) {
7642 writer._closedPromise = new Promise(function (resolve, reject) {
7643 writer._closedPromise_resolve = resolve;
7644 writer._closedPromise_reject = reject;
7645 writer._closedPromiseState = 'pending';
7649 function defaultWriterClosedPromiseInitializeAsRejected(writer, reason) {
7650 writer._closedPromise = Promise.reject(reason);
7651 writer._closedPromise_resolve = undefined;
7652 writer._closedPromise_reject = undefined;
7653 writer._closedPromiseState = 'rejected';
7656 function defaultWriterClosedPromiseInitializeAsResolved(writer) {
7657 writer._closedPromise = Promise.resolve(undefined);
7658 writer._closedPromise_resolve = undefined;
7659 writer._closedPromise_reject = undefined;
7660 writer._closedPromiseState = 'resolved';
7663 function defaultWriterClosedPromiseReject(writer, reason) {
7664 …assert(writer._closedPromise_resolve !== undefined, 'writer._closedPromise_resolve !== undefined');
7665 … assert(writer._closedPromise_reject !== undefined, 'writer._closedPromise_reject !== undefined');
7666 assert(writer._closedPromiseState === 'pending', 'writer._closedPromiseState is pending');
7668 writer._closedPromise_reject(reason);
7670 writer._closedPromise_resolve = undefined;
7671 writer._closedPromise_reject = undefined;
7672 writer._closedPromiseState = 'rejected';
7675 function defaultWriterClosedPromiseResetToRejected(writer, reason) {
7676 …assert(writer._closedPromise_resolve === undefined, 'writer._closedPromise_resolve === undefined');
7677 … assert(writer._closedPromise_reject === undefined, 'writer._closedPromise_reject === undefined');
7678 assert(writer._closedPromiseState !== 'pending', 'writer._closedPromiseState is not pending');
7679 writer._closedPromise = Promise.reject(reason);
7680 writer._closedPromiseState = 'rejected';
7683 function defaultWriterClosedPromiseResolve(writer) {
7684 …assert(writer._closedPromise_resolve !== undefined, 'writer._closedPromise_resolve !== undefined');
7685 … assert(writer._closedPromise_reject !== undefined, 'writer._closedPromise_reject !== undefined');
7686 assert(writer._closedPromiseState === 'pending', 'writer._closedPromiseState is pending');
7688 writer._closedPromise_resolve(undefined);
7690 writer._closedPromise_resolve = undefined;
7691 writer._closedPromise_reject = undefined;
7692 writer._closedPromiseState = 'resolved';
7695 function defaultWriterReadyPromiseInitialize(writer) {
7696 writer._readyPromise = new Promise(function (resolve, reject) {
7697 writer._readyPromise_resolve = resolve;
7698 writer._readyPromise_reject = reject;
7700 writer._readyPromiseState = 'pending';
7703 function defaultWriterReadyPromiseInitializeAsRejected(writer, reason) {
7704 writer._readyPromise = Promise.reject(reason);
7705 writer._readyPromise_resolve = undefined;
7706 writer._readyPromise_reject = undefined;
7707 writer._readyPromiseState = 'rejected';
7710 function defaultWriterReadyPromiseInitializeAsResolved(writer) {
7711 writer._readyPromise = Promise.resolve(undefined);
7712 writer._readyPromise_resolve = undefined;
7713 writer._readyPromise_reject = undefined;
7714 writer._readyPromiseState = 'fulfilled';
7717 function defaultWriterReadyPromiseReject(writer, reason) {
7718 … assert(writer._readyPromise_resolve !== undefined, 'writer._readyPromise_resolve !== undefined');
7719 assert(writer._readyPromise_reject !== undefined, 'writer._readyPromise_reject !== undefined');
7721 writer._readyPromise_reject(reason);
7723 writer._readyPromise_resolve = undefined;
7724 writer._readyPromise_reject = undefined;
7725 writer._readyPromiseState = 'rejected';
7728 function defaultWriterReadyPromiseReset(writer) {
7729 … assert(writer._readyPromise_resolve === undefined, 'writer._readyPromise_resolve === undefined');
7730 assert(writer._readyPromise_reject === undefined, 'writer._readyPromise_reject === undefined');
7731 writer._readyPromise = new Promise(function (resolve, reject) {
7732 writer._readyPromise_resolve = resolve;
7733 writer._readyPromise_reject = reject;
7735 writer._readyPromiseState = 'pending';
7738 function defaultWriterReadyPromiseResetToRejected(writer, reason) {
7739 … assert(writer._readyPromise_resolve === undefined, 'writer._readyPromise_resolve === undefined');
7740 assert(writer._readyPromise_reject === undefined, 'writer._readyPromise_reject === undefined');
7741 writer._readyPromise = Promise.reject(reason);
7742 writer._readyPromiseState = 'rejected';
7745 function defaultWriterReadyPromiseResolve(writer) {
7746 … assert(writer._readyPromise_resolve !== undefined, 'writer._readyPromise_resolve !== undefined');
7747 assert(writer._readyPromise_reject !== undefined, 'writer._readyPromise_reject !== undefined');
7749 writer._readyPromise_resolve(undefined);
7751 writer._readyPromise_resolve = undefined;
7752 writer._readyPromise_reject = undefined;
7753 writer._readyPromiseState = 'fulfilled';
7978 var writer = AcquireWritableStreamDefaultWriter(dest);
7989 return writer._readyPromise.then(function () {
7998 … currentWrite = WritableStreamDefaultWriterWrite(writer, value)["catch"](function () {});
8012 isOrBecomesErrored(dest, writer._closedPromise, function (storedError) {
8024 return WritableStreamDefaultWriterCloseWithErrorPropagation(writer);
8110 WritableStreamDefaultWriterRelease(writer);