File tree Expand file tree Collapse file tree 1 file changed +3
-11
lines changed Expand file tree Collapse file tree 1 file changed +3
-11
lines changed Original file line number Diff line number Diff line change @@ -31,11 +31,7 @@ class TestStreamSubscriptionFactory implements StreamSubscriptionFactory {
31
31
this . streams . set ( `${ runId } :${ streamKey } ` , chunks ) ;
32
32
}
33
33
34
- createSubscription (
35
- metadata : Record < string , unknown > ,
36
- runId : string ,
37
- streamKey : string
38
- ) : StreamSubscription {
34
+ createSubscription ( runId : string , streamKey : string ) : StreamSubscription {
39
35
const chunks = this . streams . get ( `${ runId } :${ streamKey } ` ) ?? [ ] ;
40
36
return new TestStreamSubscription ( chunks ) ;
41
37
}
@@ -285,13 +281,9 @@ describe("RunSubscription", () => {
285
281
286
282
// Override createSubscription to count calls
287
283
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 ) => {
293
285
streamCreationCount ++ ;
294
- return originalCreate ( metadata , runId , streamKey ) ;
286
+ return originalCreate ( runId , streamKey ) ;
295
287
} ;
296
288
297
289
// Set up test chunks
You can’t perform that action at this time.
0 commit comments