Make RxObservableQuery async

CHANGELOG.md

@@ -3,6 +3,7 @@
 ### vNEXT
 
 - Use `lodash` instead of individual packages [PR #14](https://github.com/kamilkisiela/apollo-client-rxjs/pull/14)
+- Made every `RxObservableQuery` asynchronous [PR #13](https://github.com/kamilkisiela/apollo-client-rxjs/pull/13)
 
 ### v0.2.3
 

package.json

@@ -28,7 +28,7 @@
     "test-watch": "mocha --reporter spec --full-trace build/tests/index.js --watch",
     "coverage": "istanbul cover ./node_modules/mocha/bin/_mocha -- --reporter dot --full-trace build/tests/index.js",
     "postcoverage": "remap-istanbul --input coverage/coverage.json --type lcovonly --output coverage/lcov.info",
-    "lint": "tslint -e src/*.ts && tslint tests/*.ts",
+    "lint": "tslint src/**/*.ts && tslint tests/*.ts",
     "prebuild": "npm run clean:build",
     "build": "tsc",
     "watch": "tsc -w",

src/rxify.ts

@@ -1,4 +1,7 @@
 import { ApolloClient, ApolloQueryResult, ObservableQuery } from 'apollo-client';
+import { observeOn } from 'rxjs/operator/observeOn';
+import { AsyncAction } from 'rxjs/scheduler/AsyncAction';
+import { AsyncScheduler } from 'rxjs/scheduler/AsyncScheduler';
 
 import { createWithObservableVariables } from './utils/variables';
 import { RxObservableQuery } from './RxObservableQuery';
@@ -30,17 +33,21 @@ export function rxify(
   throw new Error('Use ApolloClient or a function that returns ObservableQuery');
 }
 
+function wrapAsync<T>(obs: RxObservableQuery<T>): RxObservableQuery<T> {
+  return observeOn.call(obs, new AsyncScheduler(AsyncAction));
+}
+
 function wrapWatchQuery(
   watchQuery: WatchQueryFn
 ): WatchQueryRxFn {
   return (options) => {
     if (typeof options.variables === 'object') {
-      return createWithObservableVariables(
+      return wrapAsync(createWithObservableVariables(
         options,
         (newOptions) => watchQuery(newOptions)
-      );
+      ));
     }
 
-    return new RxObservableQuery(watchQuery(options));
+    return wrapAsync(new RxObservableQuery(watchQuery(options)));
   };
 }