fix(stream): remove a duplicate call

yume-chan · Dec 22, 2023 · 4494e1b · 4494e1b
1 parent 19bb1c4
commit 4494e1b
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/libraries/stream-extra/src/consumable.ts b/libraries/stream-extra/src/consumable.ts
@@ -47,15 +47,15 @@ export class Consumable<T> {
         this.#resolver.resolve();
     }
 
-    error(error: any) {
+    error(error: unknown) {
         this.#resolver.reject(error);
     }
 
     async tryConsume<U>(callback: (value: T) => U) {
         try {
             // eslint-disable-next-line @typescript-eslint/await-thenable
             const result = await this.#task.run(() => callback(this.value));
-            this.consume();
+            this.#resolver.resolve();
             return result;
         } catch (e) {
             this.#resolver.reject(e);
@@ -212,7 +212,6 @@ export class ConsumableWritableStream<T> extends WritableStream<Consumable<T>> {
                     await chunk.tryConsume(
                         (value) => sink.write?.(value, controller),
                     );
-                    chunk.consume();
                 },
                 abort(reason) {
                     return sink.abort?.(reason);