@@ -2,13 +2,12 @@ import { OpaqueToken, Injectable, Inject } from '@angular/core';
2
2
import { rxify } from 'apollo-client-rxjs' ;
3
3
import { ApolloClient , ApolloQueryResult , WatchQueryOptions , MutationOptions , SubscriptionOptions } from 'apollo-client' ;
4
4
import { Observable } from 'rxjs/Observable' ;
5
+ import { from } from 'rxjs/observable/from' ;
6
+ import { fromPromise } from 'rxjs/observable/fromPromise' ;
5
7
import { FragmentDefinitionNode } from 'graphql' ;
6
8
7
9
import { ApolloQueryObservable } from './ApolloQueryObservable' ;
8
10
9
- import 'rxjs/add/observable/from' ;
10
- import 'rxjs/add/observable/fromPromise' ;
11
-
12
11
export interface DeprecatedWatchQueryOptions extends WatchQueryOptions {
13
12
fragments ?: FragmentDefinitionNode [ ] ;
14
13
}
@@ -27,11 +26,11 @@ export class Angular2Apollo {
27
26
}
28
27
29
28
public query ( options : DeprecatedWatchQueryOptions ) : Observable < ApolloQueryResult > {
30
- return Observable . fromPromise ( this . client . query ( options ) ) ;
29
+ return fromPromise ( this . client . query ( options ) ) ;
31
30
}
32
31
33
32
public mutate ( options : MutationOptions ) : Observable < ApolloQueryResult > {
34
- return Observable . fromPromise ( this . client . mutate ( options ) ) ;
33
+ return fromPromise ( this . client . mutate ( options ) ) ;
35
34
}
36
35
37
36
public subscribe ( options : SubscriptionOptions ) : Observable < any > {
@@ -40,7 +39,7 @@ export class Angular2Apollo {
40
39
throw new Error ( `Your version of ApolloClient doesn't support subscriptions` ) ;
41
40
}
42
41
43
- return Observable . from ( this . client . subscribe ( options ) ) ;
42
+ return from ( this . client . subscribe ( options ) ) ;
44
43
}
45
44
46
45
public getClient ( ) : ApolloClient {
0 commit comments