From ae42638b8bda83dfd18bb4638ebb2b4cb7836955 Mon Sep 17 00:00:00 2001
From: Simon Chan <1330321+yume-chan@users.noreply.github.com>
Date: Thu, 28 Aug 2025 16:36:24 +0800
Subject: [PATCH] feat(stream): support async handler in InspectStream

---
 libraries/stream-extra/src/inspect.ts | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/libraries/stream-extra/src/inspect.ts b/libraries/stream-extra/src/inspect.ts
index b95d67ab..f0bfce65 100644
--- a/libraries/stream-extra/src/inspect.ts
+++ b/libraries/stream-extra/src/inspect.ts
@@ -1,13 +1,14 @@
+import type { MaybePromiseLike } from "@yume-chan/async";
 import { TransformStream } from "./stream.js";
 
 export class InspectStream<T> extends TransformStream<T, T> {
     constructor(
-        write: (value: T) => void,
+        write: (value: T) => MaybePromiseLike<undefined>,
         extras?: { close: () => void; cancel: () => void },
     ) {
         super({
-            transform(chunk, controller) {
-                write(chunk);
+            async transform(chunk, controller) {
+                await write(chunk);
                 controller.enqueue(chunk);
             },
             flush() {