@@ -314,7 +314,7 @@ describe('Execute: stream directive', () => {
314
314
} ) ;
315
315
it ( 'Can stream a field that returns a list of promises' , async ( ) => {
316
316
const document = parse ( `
317
- query {
317
+ query {
318
318
friendList @stream(initialCount: 2) {
319
319
name
320
320
id
@@ -360,7 +360,7 @@ describe('Execute: stream directive', () => {
360
360
} ) ;
361
361
it ( 'Can stream in correct order with lists of promises' , async ( ) => {
362
362
const document = parse ( `
363
- query {
363
+ query {
364
364
friendList @stream(initialCount: 0) {
365
365
name
366
366
id
@@ -410,7 +410,7 @@ describe('Execute: stream directive', () => {
410
410
} ) ;
411
411
it ( 'Can stream a field that returns a list with nested promises' , async ( ) => {
412
412
const document = parse ( `
413
- query {
413
+ query {
414
414
friendList @stream(initialCount: 2) {
415
415
name
416
416
id
@@ -460,7 +460,7 @@ describe('Execute: stream directive', () => {
460
460
} ) ;
461
461
it ( 'Handles rejections in a field that returns a list of promises before initialCount is reached' , async ( ) => {
462
462
const document = parse ( `
463
- query {
463
+ query {
464
464
friendList @stream(initialCount: 2) {
465
465
name
466
466
id
@@ -505,7 +505,7 @@ describe('Execute: stream directive', () => {
505
505
} ) ;
506
506
it ( 'Handles rejections in a field that returns a list of promises after initialCount is reached' , async ( ) => {
507
507
const document = parse ( `
508
- query {
508
+ query {
509
509
friendList @stream(initialCount: 1) {
510
510
name
511
511
id
@@ -559,7 +559,7 @@ describe('Execute: stream directive', () => {
559
559
} ) ;
560
560
it ( 'Can stream a field that returns an async iterable' , async ( ) => {
561
561
const document = parse ( `
562
- query {
562
+ query {
563
563
friendList @stream {
564
564
name
565
565
id
@@ -616,7 +616,7 @@ describe('Execute: stream directive', () => {
616
616
} ) ;
617
617
it ( 'Can stream a field that returns an async iterable, using a non-zero initialCount' , async ( ) => {
618
618
const document = parse ( `
619
- query {
619
+ query {
620
620
friendList @stream(initialCount: 2) {
621
621
name
622
622
id
@@ -658,7 +658,7 @@ describe('Execute: stream directive', () => {
658
658
} ) ;
659
659
it ( 'Negative values of initialCount throw field errors on a field that returns an async iterable' , async ( ) => {
660
660
const document = parse ( `
661
- query {
661
+ query {
662
662
friendList @stream(initialCount: -2) {
663
663
name
664
664
id
@@ -684,7 +684,7 @@ describe('Execute: stream directive', () => {
684
684
} ) ;
685
685
it ( 'Can handle concurrent calls to .next() without waiting' , async ( ) => {
686
686
const document = parse ( `
687
- query {
687
+ query {
688
688
friendList @stream(initialCount: 2) {
689
689
name
690
690
id
@@ -736,7 +736,7 @@ describe('Execute: stream directive', () => {
736
736
} ) ;
737
737
it ( 'Handles error thrown in async iterable before initialCount is reached' , async ( ) => {
738
738
const document = parse ( `
739
- query {
739
+ query {
740
740
friendList @stream(initialCount: 2) {
741
741
name
742
742
id
@@ -764,7 +764,7 @@ describe('Execute: stream directive', () => {
764
764
} ) ;
765
765
it ( 'Handles error thrown in async iterable after initialCount is reached' , async ( ) => {
766
766
const document = parse ( `
767
- query {
767
+ query {
768
768
friendList @stream(initialCount: 1) {
769
769
name
770
770
id
@@ -804,7 +804,7 @@ describe('Execute: stream directive', () => {
804
804
} ) ;
805
805
it ( 'Handles null returned in non-null list items after initialCount is reached' , async ( ) => {
806
806
const document = parse ( `
807
- query {
807
+ query {
808
808
nonNullFriendList @stream(initialCount: 1) {
809
809
name
810
810
}
@@ -842,7 +842,7 @@ describe('Execute: stream directive', () => {
842
842
} ) ;
843
843
it ( 'Handles null returned in non-null async iterable list items after initialCount is reached' , async ( ) => {
844
844
const document = parse ( `
845
- query {
845
+ query {
846
846
nonNullFriendList @stream(initialCount: 1) {
847
847
name
848
848
}
@@ -889,7 +889,7 @@ describe('Execute: stream directive', () => {
889
889
} ) ;
890
890
it ( 'Handles errors thrown by completeValue after initialCount is reached' , async ( ) => {
891
891
const document = parse ( `
892
- query {
892
+ query {
893
893
scalarList @stream(initialCount: 1)
894
894
}
895
895
` ) ;
@@ -925,7 +925,7 @@ describe('Execute: stream directive', () => {
925
925
} ) ;
926
926
it ( 'Handles async errors thrown by completeValue after initialCount is reached' , async ( ) => {
927
927
const document = parse ( `
928
- query {
928
+ query {
929
929
friendList @stream(initialCount: 1) {
930
930
nonNullName
931
931
}
@@ -978,7 +978,7 @@ describe('Execute: stream directive', () => {
978
978
} ) ;
979
979
it ( 'Handles nested async errors thrown by completeValue after initialCount is reached' , async ( ) => {
980
980
const document = parse ( `
981
- query {
981
+ query {
982
982
friendList @stream(initialCount: 1) {
983
983
nonNullName
984
984
}
@@ -1029,7 +1029,7 @@ describe('Execute: stream directive', () => {
1029
1029
} ) ;
1030
1030
it ( 'Handles async errors thrown by completeValue after initialCount is reached for a non-nullable list' , async ( ) => {
1031
1031
const document = parse ( `
1032
- query {
1032
+ query {
1033
1033
nonNullFriendList @stream(initialCount: 1) {
1034
1034
nonNullName
1035
1035
}
@@ -1071,7 +1071,7 @@ describe('Execute: stream directive', () => {
1071
1071
} ) ;
1072
1072
it ( 'Handles nested async errors thrown by completeValue after initialCount is reached for a non-nullable list' , async ( ) => {
1073
1073
const document = parse ( `
1074
- query {
1074
+ query {
1075
1075
nonNullFriendList @stream(initialCount: 1) {
1076
1076
nonNullName
1077
1077
}
@@ -1111,7 +1111,7 @@ describe('Execute: stream directive', () => {
1111
1111
} ) ;
1112
1112
it ( 'Handles async errors thrown by completeValue after initialCount is reached from async iterable' , async ( ) => {
1113
1113
const document = parse ( `
1114
- query {
1114
+ query {
1115
1115
friendList @stream(initialCount: 1) {
1116
1116
nonNullName
1117
1117
}
@@ -1167,7 +1167,7 @@ describe('Execute: stream directive', () => {
1167
1167
} ) ;
1168
1168
it ( 'Handles async errors thrown by completeValue after initialCount is reached from async generator for a non-nullable list' , async ( ) => {
1169
1169
const document = parse ( `
1170
- query {
1170
+ query {
1171
1171
nonNullFriendList @stream(initialCount: 1) {
1172
1172
nonNullName
1173
1173
}
@@ -1211,7 +1211,7 @@ describe('Execute: stream directive', () => {
1211
1211
} ) ;
1212
1212
it ( 'Handles async errors thrown by completeValue after initialCount is reached from async iterable for a non-nullable list when the async iterable does not provide a return method) ' , async ( ) => {
1213
1213
const document = parse ( `
1214
- query {
1214
+ query {
1215
1215
nonNullFriendList @stream(initialCount: 1) {
1216
1216
nonNullName
1217
1217
}
@@ -1279,7 +1279,7 @@ describe('Execute: stream directive', () => {
1279
1279
} ) ;
1280
1280
it ( 'Handles async errors thrown by completeValue after initialCount is reached from async iterable for a non-nullable list when the async iterable provides concurrent next/return methods and has a slow return ' , async ( ) => {
1281
1281
const document = parse ( `
1282
- query {
1282
+ query {
1283
1283
nonNullFriendList @stream(initialCount: 1) {
1284
1284
nonNullName
1285
1285
}
@@ -1358,7 +1358,7 @@ describe('Execute: stream directive', () => {
1358
1358
} ) ;
1359
1359
it ( 'Filters payloads that are nulled' , async ( ) => {
1360
1360
const document = parse ( `
1361
- query {
1361
+ query {
1362
1362
nestedObject {
1363
1363
nonNullScalarField
1364
1364
nestedFriendList @stream(initialCount: 0) {
@@ -1391,7 +1391,7 @@ describe('Execute: stream directive', () => {
1391
1391
} ) ;
1392
1392
it ( 'Filters payloads that are nulled by a later synchronous error' , async ( ) => {
1393
1393
const document = parse ( `
1394
- query {
1394
+ query {
1395
1395
nestedObject {
1396
1396
nestedFriendList @stream(initialCount: 0) {
1397
1397
name
@@ -1424,7 +1424,7 @@ describe('Execute: stream directive', () => {
1424
1424
} ) ;
1425
1425
it ( 'Does not filter payloads when null error is in a different path' , async ( ) => {
1426
1426
const document = parse ( `
1427
- query {
1427
+ query {
1428
1428
otherNestedObject: nestedObject {
1429
1429
... @defer {
1430
1430
scalarField
@@ -1486,7 +1486,7 @@ describe('Execute: stream directive', () => {
1486
1486
} ) ;
1487
1487
it ( 'Filters stream payloads that are nulled in a deferred payload' , async ( ) => {
1488
1488
const document = parse ( `
1489
- query {
1489
+ query {
1490
1490
nestedObject {
1491
1491
... @defer {
1492
1492
deeperNestedObject {
@@ -1545,7 +1545,7 @@ describe('Execute: stream directive', () => {
1545
1545
} ) ;
1546
1546
it ( 'Filters defer payloads that are nulled in a stream response' , async ( ) => {
1547
1547
const document = parse ( `
1548
- query {
1548
+ query {
1549
1549
friendList @stream(initialCount: 0) {
1550
1550
nonNullName
1551
1551
... @defer {
@@ -1624,7 +1624,7 @@ describe('Execute: stream directive', () => {
1624
1624
} ;
1625
1625
1626
1626
const document = parse ( `
1627
- query {
1627
+ query {
1628
1628
nestedObject {
1629
1629
... @defer {
1630
1630
deeperNestedObject {
@@ -1698,7 +1698,7 @@ describe('Execute: stream directive', () => {
1698
1698
} ) ;
1699
1699
it ( 'Handles promises returned by completeValue after initialCount is reached' , async ( ) => {
1700
1700
const document = parse ( `
1701
- query {
1701
+ query {
1702
1702
friendList @stream(initialCount: 1) {
1703
1703
id
1704
1704
name
@@ -1815,7 +1815,7 @@ describe('Execute: stream directive', () => {
1815
1815
const { promise : slowFieldPromise , resolve : resolveSlowField } =
1816
1816
promiseWithResolvers ( ) ;
1817
1817
const document = parse ( `
1818
- query {
1818
+ query {
1819
1819
nestedObject {
1820
1820
... DeferFragment @defer
1821
1821
}
@@ -1918,7 +1918,7 @@ describe('Execute: stream directive', () => {
1918
1918
} = promiseWithResolvers ( ) ;
1919
1919
1920
1920
const document = parse ( `
1921
- query {
1921
+ query {
1922
1922
friendList @stream(initialCount: 1, label:"stream-label") {
1923
1923
...NameFragment @defer(label: "DeferName") @defer(label: "DeferName")
1924
1924
id
@@ -2019,7 +2019,7 @@ describe('Execute: stream directive', () => {
2019
2019
} = promiseWithResolvers ( ) ;
2020
2020
2021
2021
const document = parse ( `
2022
- query {
2022
+ query {
2023
2023
friendList @stream(initialCount: 1, label:"stream-label") {
2024
2024
...NameFragment @defer(label: "DeferName") @defer(label: "DeferName")
2025
2025
id
@@ -2131,7 +2131,7 @@ describe('Execute: stream directive', () => {
2131
2131
} ;
2132
2132
2133
2133
const document = parse ( `
2134
- query {
2134
+ query {
2135
2135
friendList @stream(initialCount: 1) {
2136
2136
id
2137
2137
... @defer {
@@ -2191,7 +2191,7 @@ describe('Execute: stream directive', () => {
2191
2191
} ;
2192
2192
2193
2193
const document = parse ( `
2194
- query {
2194
+ query {
2195
2195
friendList @stream(initialCount: 1) {
2196
2196
name
2197
2197
id
@@ -2250,7 +2250,7 @@ describe('Execute: stream directive', () => {
2250
2250
} ) ,
2251
2251
} ;
2252
2252
const document = parse ( `
2253
- query {
2253
+ query {
2254
2254
friendList @stream(initialCount: 1) {
2255
2255
... @defer {
2256
2256
name
0 commit comments