Skip to content

Commit d2ec40b

Browse files
committed
Fixed run stream tests
1 parent de13e3c commit d2ec40b

File tree

1 file changed

+3
-11
lines changed

1 file changed

+3
-11
lines changed

packages/core/test/runStream.test.ts

Lines changed: 3 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -31,11 +31,7 @@ class TestStreamSubscriptionFactory implements StreamSubscriptionFactory {
3131
this.streams.set(`${runId}:${streamKey}`, chunks);
3232
}
3333

34-
createSubscription(
35-
metadata: Record<string, unknown>,
36-
runId: string,
37-
streamKey: string
38-
): StreamSubscription {
34+
createSubscription(runId: string, streamKey: string): StreamSubscription {
3935
const chunks = this.streams.get(`${runId}:${streamKey}`) ?? [];
4036
return new TestStreamSubscription(chunks);
4137
}
@@ -285,13 +281,9 @@ describe("RunSubscription", () => {
285281

286282
// Override createSubscription to count calls
287283
const originalCreate = streamFactory.createSubscription.bind(streamFactory);
288-
streamFactory.createSubscription = (
289-
metadata: Record<string, unknown>,
290-
runId: string,
291-
streamKey: string
292-
) => {
284+
streamFactory.createSubscription = (runId: string, streamKey: string) => {
293285
streamCreationCount++;
294-
return originalCreate(metadata, runId, streamKey);
286+
return originalCreate(runId, streamKey);
295287
};
296288

297289
// Set up test chunks

0 commit comments

Comments
 (0)