@@ -6,7 +6,7 @@ import { marbles } from "rxjs-marbles/jest";
6
6
import { makeExecutableSchema } from "graphql-tools" ;
7
7
import gql from "graphql-tag" ;
8
8
9
- import graphqlObservable from "../" ;
9
+ import { graphql } from "../" ;
10
10
11
11
const typeDefs = `
12
12
type Shuttle {
@@ -196,7 +196,7 @@ describe("graphqlObservable", function() {
196
196
a : { data : { launched : expectedData } }
197
197
} ) ;
198
198
199
- const result = graphqlObservable ( query , schema , { query : dataSource } ) ;
199
+ const result = graphql ( query , schema , { query : dataSource } ) ;
200
200
201
201
m . expect ( result . pipe ( take ( 1 ) ) ) . toBeObservable ( expected ) ;
202
202
} ) ;
@@ -218,11 +218,16 @@ describe("graphqlObservable", function() {
218
218
} ) ;
219
219
220
220
const nameFilter = of ( "apollo11" ) ;
221
- const result = graphqlObservable ( query , schema , {
222
- query : dataSource
223
- } , {
224
- nameFilter
225
- } ) ;
221
+ const result = graphql (
222
+ query ,
223
+ schema ,
224
+ {
225
+ query : dataSource
226
+ } ,
227
+ {
228
+ nameFilter
229
+ }
230
+ ) ;
226
231
227
232
m . expect ( result . pipe ( take ( 1 ) ) ) . toBeObservable ( expected ) ;
228
233
} ) ;
@@ -243,7 +248,7 @@ describe("graphqlObservable", function() {
243
248
a : { data : { launched : [ expectedData [ 0 ] ] } }
244
249
} ) ;
245
250
246
- const result = graphqlObservable ( query , schema , {
251
+ const result = graphql ( query , schema , {
247
252
query : dataSource
248
253
} ) ;
249
254
@@ -265,7 +270,7 @@ describe("graphqlObservable", function() {
265
270
a : { data : { launched : [ { name : "discovery" } ] } }
266
271
} ) ;
267
272
268
- const result = graphqlObservable ( query , schema , {
273
+ const result = graphql ( query , schema , {
269
274
query : dataSource
270
275
} ) ;
271
276
@@ -287,7 +292,7 @@ describe("graphqlObservable", function() {
287
292
a : { data : { launched : [ { title : "challenger" } ] } }
288
293
} ) ;
289
294
290
- const result = graphqlObservable ( query , schema , {
295
+ const result = graphql ( query , schema , {
291
296
query : dataSource
292
297
} ) ;
293
298
@@ -307,7 +312,7 @@ describe("graphqlObservable", function() {
307
312
const expected = m . cold ( "(a|)" , {
308
313
a : { data : { plain : { noFieldResolver : "Yes" } } }
309
314
} ) ;
310
- const result = graphqlObservable ( query , fieldResolverSchema , { } ) ;
315
+ const result = graphql ( query , fieldResolverSchema , { } ) ;
311
316
m . expect ( result . pipe ( take ( 1 ) ) ) . toBeObservable ( expected ) ;
312
317
} ) ;
313
318
@@ -322,7 +327,7 @@ describe("graphqlObservable", function() {
322
327
const expected = m . cold ( "(a|)" , {
323
328
a : { data : { plain : { fieldResolver : "I am a field resolver" } } }
324
329
} ) ;
325
- const result = graphqlObservable ( query , fieldResolverSchema , { } ) ;
330
+ const result = graphql ( query , fieldResolverSchema , { } ) ;
326
331
m . expect ( result . pipe ( take ( 1 ) ) ) . toBeObservable ( expected ) ;
327
332
} ) ;
328
333
@@ -345,7 +350,7 @@ describe("graphqlObservable", function() {
345
350
}
346
351
}
347
352
} ) ;
348
- const result = graphqlObservable ( query , fieldResolverSchema , { } ) ;
353
+ const result = graphql ( query , fieldResolverSchema , { } ) ;
349
354
m . expect ( result . pipe ( take ( 1 ) ) ) . toBeObservable ( expected ) ;
350
355
} ) ;
351
356
@@ -368,7 +373,7 @@ describe("graphqlObservable", function() {
368
373
}
369
374
}
370
375
} ) ;
371
- const result = graphqlObservable ( query , fieldResolverSchema , { } ) ;
376
+ const result = graphql ( query , fieldResolverSchema , { } ) ;
372
377
m . expect ( result . pipe ( take ( 1 ) ) ) . toBeObservable ( expected ) ;
373
378
} ) ;
374
379
@@ -389,7 +394,7 @@ describe("graphqlObservable", function() {
389
394
}
390
395
}
391
396
} ) ;
392
- const result = graphqlObservable ( query , fieldResolverSchema , { } ) ;
397
+ const result = graphql ( query , fieldResolverSchema , { } ) ;
393
398
m . expect ( result . pipe ( take ( 1 ) ) ) . toBeObservable ( expected ) ;
394
399
} ) ;
395
400
} ) ;
@@ -414,7 +419,7 @@ describe("graphqlObservable", function() {
414
419
}
415
420
}
416
421
} ) ;
417
- const result = graphqlObservable ( query , fieldResolverSchema , { } ) ;
422
+ const result = graphql ( query , fieldResolverSchema , { } ) ;
418
423
m . expect ( result . pipe ( take ( 1 ) ) ) . toBeObservable ( expected ) ;
419
424
} ) ;
420
425
@@ -441,7 +446,7 @@ describe("graphqlObservable", function() {
441
446
}
442
447
}
443
448
} ) ;
444
- const result = graphqlObservable ( query , fieldResolverSchema , { } ) ;
449
+ const result = graphql ( query , fieldResolverSchema , { } ) ;
445
450
m . expect ( result . pipe ( take ( 1 ) ) ) . toBeObservable ( expected ) ;
446
451
} ) ;
447
452
@@ -468,7 +473,7 @@ describe("graphqlObservable", function() {
468
473
}
469
474
}
470
475
} ) ;
471
- const result = graphqlObservable ( query , fieldResolverSchema , { } ) ;
476
+ const result = graphql ( query , fieldResolverSchema , { } ) ;
472
477
m . expect ( result . pipe ( take ( 1 ) ) ) . toBeObservable ( expected ) ;
473
478
} ) ;
474
479
@@ -491,7 +496,7 @@ describe("graphqlObservable", function() {
491
496
}
492
497
}
493
498
} ) ;
494
- const result = graphqlObservable ( query , fieldResolverSchema , { } ) ;
499
+ const result = graphql ( query , fieldResolverSchema , { } ) ;
495
500
m . expect ( result . pipe ( take ( 1 ) ) ) . toBeObservable ( expected ) ;
496
501
} ) ;
497
502
} ) ;
@@ -521,7 +526,7 @@ describe("graphqlObservable", function() {
521
526
}
522
527
}
523
528
} ) ;
524
- const result = graphqlObservable ( query , fieldResolverSchema , { } ) ;
529
+ const result = graphql ( query , fieldResolverSchema , { } ) ;
525
530
m . expect ( result . pipe ( take ( 1 ) ) ) . toBeObservable ( expected ) ;
526
531
} ) ;
527
532
} ) ;
@@ -539,7 +544,7 @@ describe("graphqlObservable", function() {
539
544
"reactive-graphql: resolver 'throwingResolver' throws this error: 'Error: my personal error'"
540
545
)
541
546
) ;
542
- const result = graphqlObservable ( query , fieldResolverSchema , { } ) ;
547
+ const result = graphql ( query , fieldResolverSchema , { } ) ;
543
548
m . expect ( result . pipe ( take ( 1 ) ) ) . toBeObservable ( expected ) ;
544
549
} ) ;
545
550
@@ -558,7 +563,7 @@ describe("graphqlObservable", function() {
558
563
"reactive-graphql: field 'youDontKnowMe' was not found on type 'Query'. The only fields found in this Object are: plain,item,nested,throwingResolver."
559
564
)
560
565
) ;
561
- const result = graphqlObservable ( query , fieldResolverSchema , { } ) ;
566
+ const result = graphql ( query , fieldResolverSchema , { } ) ;
562
567
m . expect ( result . pipe ( take ( 1 ) ) ) . toBeObservable ( expected ) ;
563
568
}
564
569
) ;
@@ -577,7 +582,7 @@ describe("graphqlObservable", function() {
577
582
const fakeRequest = { name : "RocketShip" } ;
578
583
const commandContext = of ( fakeRequest ) ;
579
584
580
- const result = graphqlObservable ( mutation , schema , {
585
+ const result = graphql ( mutation , schema , {
581
586
mutation : commandContext
582
587
} ) ;
583
588
@@ -601,7 +606,7 @@ describe("graphqlObservable", function() {
601
606
602
607
const commandContext = of ( "a request" ) ;
603
608
604
- const result = graphqlObservable ( mutation , schema , {
609
+ const result = graphql ( mutation , schema , {
605
610
mutation : commandContext
606
611
} ) ;
607
612
@@ -634,9 +639,14 @@ describe("graphqlObservable", function() {
634
639
const variables = {
635
640
name : "RocketShip"
636
641
} ;
637
- const result = graphqlObservable ( mutation , schema , {
638
- mutation : commandContext ,
639
- } , variables ) ;
642
+ const result = graphql (
643
+ mutation ,
644
+ schema ,
645
+ {
646
+ mutation : commandContext
647
+ } ,
648
+ variables
649
+ ) ;
640
650
641
651
const expected = m . cold ( "(a|)" , {
642
652
a : { data : { shut : { name : "RocketShip" } } }
0 commit comments