Skip to content

Commit b58a646

Browse files
committed
Fixed runStream tests
1 parent 9ea203b commit b58a646

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

packages/core/test/runStream.test.ts

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -103,6 +103,7 @@ describe("RunSubscription", () => {
103103

104104
const subscription = new RunSubscription({
105105
runShapeStream: createTestShapeStream(shapes),
106+
stopRunShapeStream: () => {},
106107
streamFactory: new TestStreamSubscriptionFactory(),
107108
closeOnComplete: true,
108109
abortController: new AbortController(),
@@ -143,6 +144,7 @@ describe("RunSubscription", () => {
143144

144145
const subscription = new RunSubscription({
145146
runShapeStream: createTestShapeStream(shapes),
147+
stopRunShapeStream: () => {},
146148
streamFactory: new TestStreamSubscriptionFactory(),
147149
closeOnComplete: true,
148150
abortController: new AbortController(),
@@ -196,6 +198,7 @@ describe("RunSubscription", () => {
196198

197199
const subscription = new RunSubscription({
198200
runShapeStream: createDelayedTestShapeStream(shapes),
201+
stopRunShapeStream: () => {},
199202
streamFactory: new TestStreamSubscriptionFactory(),
200203
closeOnComplete: false,
201204
abortController: new AbortController(),
@@ -249,6 +252,7 @@ describe("RunSubscription", () => {
249252

250253
const subscription = new RunSubscription({
251254
runShapeStream: createTestShapeStream(shapes),
255+
stopRunShapeStream: () => {},
252256
streamFactory,
253257
abortController: new AbortController(),
254258
});
@@ -339,6 +343,7 @@ describe("RunSubscription", () => {
339343

340344
const subscription = new RunSubscription({
341345
runShapeStream: createTestShapeStream(shapes),
346+
stopRunShapeStream: () => {},
342347
streamFactory,
343348
abortController: new AbortController(),
344349
});
@@ -419,6 +424,7 @@ describe("RunSubscription", () => {
419424

420425
const subscription = new RunSubscription({
421426
runShapeStream: createTestShapeStream(shapes),
427+
stopRunShapeStream: () => {},
422428
streamFactory,
423429
abortController: new AbortController(),
424430
});

0 commit comments

Comments
 (0)