fix(node:stream): support asyncDispose for readable

unjs · Aug 22, 2023 · f8f8f46 · f8f8f46
1 parent 16f6150
commit f8f8f46
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/runtime/node/stream/readable.ts b/src/runtime/node/stream/readable.ts
@@ -85,6 +85,11 @@ export class _Readable extends EventEmitter implements stream.Readable {
 
   async *[Symbol.asyncIterator](): AsyncIterableIterator<any> {}
 
+  [Symbol.asyncDispose]() {
+    this.destroy();
+    return Promise.resolve();
+  }
+
   compose<T extends NodeJS.ReadableStream>(
     stream: T | ((source: any) => void) | Iterable<T> | AsyncIterable<T>,
     options?: { signal: AbortSignal } | undefined,