@@ -14,7 +14,7 @@ import { GraphQLList, GraphQLObjectType } from '../../type/definition';
14
14
import { GraphQLBoolean , GraphQLInt , GraphQLString } from '../../type/scalars' ;
15
15
import { GraphQLSchema } from '../../type/schema' ;
16
16
17
- import type { ExecutionResult } from '../execute' ;
17
+ import type { ExecutionArgs , ExecutionResult } from '../execute' ;
18
18
import { createSourceEventStream , subscribe } from '../execute' ;
19
19
20
20
import { SimplePubSub } from './simplePubSub' ;
@@ -195,6 +195,15 @@ function subscribeWithBadFn(
195
195
) ;
196
196
}
197
197
198
+ function subscribeWithBadArgs (
199
+ args : ExecutionArgs ,
200
+ ) : PromiseOrValue < ExecutionResult | AsyncIterable < unknown > > {
201
+ return expectEqualPromisesOrValues (
202
+ subscribe ( args ) ,
203
+ createSourceEventStream ( args ) ,
204
+ ) ;
205
+ }
206
+
198
207
/* eslint-disable @typescript-eslint/require-await */
199
208
// Check all error cases when initializing the subscription.
200
209
describe ( 'Subscription Initialization Phase' , ( ) => {
@@ -394,7 +403,7 @@ describe('Subscription Initialization Phase', () => {
394
403
const schema = new GraphQLSchema ( { query : DummyQueryType } ) ;
395
404
const document = parse ( 'subscription { unknownField }' ) ;
396
405
397
- const result = subscribe ( { schema, document } ) ;
406
+ const result = subscribeWithBadArgs ( { schema, document } ) ;
398
407
expectJSON ( result ) . toDeepEqual ( {
399
408
errors : [
400
409
{
@@ -418,7 +427,7 @@ describe('Subscription Initialization Phase', () => {
418
427
} ) ;
419
428
const document = parse ( 'subscription { unknownField }' ) ;
420
429
421
- const result = subscribe ( { schema, document } ) ;
430
+ const result = subscribeWithBadArgs ( { schema, document } ) ;
422
431
expectJSON ( result ) . toDeepEqual ( {
423
432
errors : [
424
433
{
@@ -441,7 +450,7 @@ describe('Subscription Initialization Phase', () => {
441
450
} ) ;
442
451
443
452
// @ts -expect-error
444
- expect ( ( ) => subscribe ( { schema, document : { } } ) ) . to . throw ( ) ;
453
+ expect ( ( ) => subscribeWithBadArgs ( { schema, document : { } } ) ) . to . throw ( ) ;
445
454
} ) ;
446
455
447
456
it ( 'throws an error if subscribe does not return an iterator' , async ( ) => {
@@ -526,7 +535,7 @@ describe('Subscription Initialization Phase', () => {
526
535
527
536
// If we receive variables that cannot be coerced correctly, subscribe() will
528
537
// resolve to an ExecutionResult that contains an informative error description.
529
- const result = subscribe ( { schema, document, variableValues } ) ;
538
+ const result = subscribeWithBadArgs ( { schema, document, variableValues } ) ;
530
539
expectJSON ( result ) . toDeepEqual ( {
531
540
errors : [
532
541
{
0 commit comments