| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent 2f66c7e commit 56299f7
2 files changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -2034,8 +2034,8 @@ function readableStreamError(stream, error) { | |||
| 2034 | 2034 | assert(stream[kState].state === 'readable'); | |
| 2035 | 2035 | stream[kState].state = 'errored'; | |
| 2036 | 2036 | stream[kState].storedError = error; | |
| 2037 | - stream[kIsClosedPromise].reject(error); | ||
| 2038 | 2037 | setPromiseHandled(stream[kIsClosedPromise].promise); | |
| 2038 | + stream[kIsClosedPromise].reject(error); | ||
| 2039 | 2039 | ||
| 2040 | 2040 | const { | |
| 2041 | 2041 | reader, | |
@@ -2044,8 +2044,8 @@ function readableStreamError(stream, error) { | |||
| 2044 | 2044 | if (reader === undefined) | |
| 2045 | 2045 | return; | |
| 2046 | 2046 | ||
| 2047 | - reader[kState].close.reject(error); | ||
| 2048 | 2047 | setPromiseHandled(reader[kState].close.promise); | |
| 2048 | + reader[kState].close.reject(error); | ||
| 2049 | 2049 | ||
| 2050 | 2050 | if (readableStreamHasDefaultReader(stream)) { | |
| 2051 | 2051 | for (let n = 0; n < reader[kState].readRequests.length; n++) | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -761,15 +761,15 @@ function writableStreamRejectCloseAndClosedPromiseIfNeeded(stream) { | |||
| 761 | 761 | }; | |
| 762 | 762 | } | |
| 763 | 763 | ||
| 764 | - stream[kIsClosedPromise].reject(stream[kState]?.storedError); | ||
| 765 | 764 | setPromiseHandled(stream[kIsClosedPromise].promise); | |
| 765 | + stream[kIsClosedPromise].reject(stream[kState]?.storedError); | ||
| 766 | 766 | ||
| 767 | 767 | const { | |
| 768 | 768 | writer, | |
| 769 | 769 | } = stream[kState]; | |
| 770 | 770 | if (writer !== undefined) { | |
| 771 | - writer[kState].close.reject?.(stream[kState].storedError); | ||
| 772 | 771 | setPromiseHandled(writer[kState].close.promise); | |
| 772 | + writer[kState].close.reject?.(stream[kState].storedError); | ||
| 773 | 773 | } | |
| 774 | 774 | } | |
| 775 | 775 | ||
| Back | FazBrowse Home | New Git URL |
0 commit comments