Fixed core tests

Author: ericallam

packages/core/test/runStream.test.ts

@@ -1,6 +1,7 @@
 import { describe, expect, it } from "vitest";
 import {
   RunSubscription,
+  SSEStreamPart,
   StreamSubscription,
   StreamSubscriptionFactory,
 } from "../src/v3/apiClient/runStream.js";
@@ -11,11 +12,15 @@ import type { SubscribeRunRawShape } from "../src/v3/schemas/api.js";
 class TestStreamSubscription implements StreamSubscription {
   constructor(private chunks: unknown[]) {}
 
-  async subscribe(): Promise<ReadableStream<unknown>> {
+  async subscribe(): Promise<ReadableStream<SSEStreamPart<unknown>>> {
     return new ReadableStream({
       start: async (controller) => {
-        for (const chunk of this.chunks) {
-          controller.enqueue(chunk);
+        for (let i = 0; i < this.chunks.length; i++) {
+          controller.enqueue({
+            id: `msg-${i}`,
+            chunk: this.chunks[i],
+            timestamp: Date.now() + i,
+          });
         }
         controller.close();
       },