mirror of
https://github.com/denoland/deno.git
synced 2025-08-04 19:08:15 +00:00
fix(ext/node): Fix Writable.toWeb()
(#28914)
Fixes https://github.com/denoland/deno/issues/28905
This commit is contained in:
parent
a5d39b085d
commit
5867988bae
2 changed files with 28 additions and 3 deletions
|
@ -627,7 +627,7 @@ export function newWritableStreamFromStreamWritable(streamWritable) {
|
|||
|
||||
async write(chunk) {
|
||||
if (streamWritable.writableNeedDrain || !streamWritable.write(chunk)) {
|
||||
backpressurePromise = createDeferredPromise();
|
||||
backpressurePromise = Promise.withResolvers();
|
||||
return backpressurePromise.promise.finally(() => {
|
||||
backpressurePromise = undefined;
|
||||
});
|
||||
|
@ -640,7 +640,7 @@ export function newWritableStreamFromStreamWritable(streamWritable) {
|
|||
|
||||
close() {
|
||||
if (closed === undefined && !isWritableEnded(streamWritable)) {
|
||||
closed = createDeferredPromise();
|
||||
closed = Promise.withResolvers();
|
||||
streamWritable.end();
|
||||
return closed.promise;
|
||||
}
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue