@@ -80,7 +80,7 @@ describe('PubSubAsyncIterator', function() {
80
80
} ) ;
81
81
82
82
it ( 'should allow subscriptions' , ( ) =>
83
- subscribe ( schema , query )
83
+ subscribe ( { schema, document : query } )
84
84
. then ( ai => {
85
85
// tslint:disable-next-line:no-unused-expression
86
86
expect ( isAsyncIterable ( ai ) ) . to . be . true ;
@@ -95,7 +95,7 @@ describe('PubSubAsyncIterator', function() {
95
95
} ) ) ;
96
96
97
97
it ( 'should allow pattern subscriptions' , ( ) =>
98
- subscribe ( schema , patternQuery )
98
+ subscribe ( { schema, document : patternQuery } )
99
99
. then ( ai => {
100
100
// tslint:disable-next-line:no-unused-expression
101
101
expect ( isAsyncIterable ( ai ) ) . to . be . true ;
@@ -110,7 +110,7 @@ describe('PubSubAsyncIterator', function() {
110
110
} ) ) ;
111
111
112
112
it ( 'should clear event handlers' , ( ) =>
113
- subscribe ( schema , query )
113
+ subscribe ( { schema, document : query } )
114
114
. then ( ai => {
115
115
// tslint:disable-next-line:no-unused-expression
116
116
expect ( isAsyncIterable ( ai ) ) . to . be . true ;
0 commit comments