fix(reply): preserve direct block emission order

vincentkoc · vincentkoc · commit 40da4a31d27a · 2026-06-11T02:59:32.000+09:00
diff --git a/src/auto-reply/reply/reply-delivery.test.ts b/src/auto-reply/reply/reply-delivery.test.ts
@@ -423,4 +423,33 @@ describe("createBlockReplyDeliveryHandler", () => {
       assistantMessageIndex: 7,
     });
   });
+
+  it("records concurrent direct block deliveries in emission order", async () => {
+    const resolvers: Array<() => void> = [];
+    const directlySentBlockPayloads: Array<ReplyPayload | undefined> = [];
+    const handler = createBlockReplyDeliveryHandler({
+      onBlockReply: () =>
+        new Promise<void>((resolve) => {
+          resolvers.push(resolve);
+        }),
+      normalizeStreamingText: (payload) => ({ text: payload.text, skip: false }),
+      applyReplyToMode: (payload) => payload,
+      typingSignals: {
+        signalTextDelta: vi.fn(async () => {}),
+      } as unknown as TypingSignaler,
+      blockStreamingEnabled: true,
+      blockReplyPipeline: null,
+      directlySentBlockKeys: new Set(),
+      directlySentBlockPayloads,
+    });
+
+    const first = handler({ text: "first" });
+    const second = handler({ text: "second" });
+    resolvers[1]?.();
+    await second;
+    resolvers[0]?.();
+    await first;
+
+    expect(directlySentBlockPayloads.map((payload) => payload?.text)).toEqual(["first", "second"]);
+  });
 });
