Add subscribeToMore function

CHANGELOG.md

@@ -2,6 +2,7 @@
 
 ### vNEXT
 
+- Add `subscribeToMore` function [PR #5](https://github.com/kamilkisiela/apollo-client-rxjs/pull/5)
 - Added support for ApolloClient `v0.5.0` [PR #4](https://github.com/kamilkisiela/apollo-client-rxjs/pull/4)
 - BREAKING CHANGE No longer support ApolloClient `v0.4.X` [PR #4](https://github.com/kamilkisiela/apollo-client-rxjs/pull/4)
 

src/RxObservableQuery.ts

@@ -47,10 +47,13 @@ export class RxObservableQuery<T> extends Observable<T> {
   }
 
   public updateQuery(mapFn: any): void {
-    this.checkMethod('updateQuery');
     this.getObservableQuery().updateQuery(mapFn);
   }
 
+  public subscribeToMore(options: any): () => void {
+    return this.getObservableQuery().subscribeToMore(options);
+  }
+
   // where magic happens
 
   public _subscribe(subscriber: Subscriber<T>) {
@@ -73,12 +76,4 @@ export class RxObservableQuery<T> extends Observable<T> {
 
     return this.apollo as ObservableQuery;
   }
-
-  private checkMethod(method: string): void {
-    const obsQuery = this.getObservableQuery();
-
-    if (typeof obsQuery[method] === 'undefined') {
-      throw new Error(`Method '${method}' is not available in your version of ApolloClient`);
-    }
-  }
 }

tests/RxObservableQuery.ts

@@ -100,6 +100,15 @@ describe('RxObservableQuery', () => {
       assert.equal(promise, 'promise');
     });
 
+    it('should be able to subscribeToMore', () => {
+      const stubbed = stub(obsQuery, 'subscribeToMore').returns('fn');
+      const options = {};
+      const fn = rxObsQuery.subscribeToMore(options);
+
+      assert.deepEqual(stubbed.args[0], [options]);
+      assert.equal(fn, 'fn');
+    });
+
     it('should be able to updateQuery', () => {
       const stubbed = stub(obsQuery, 'updateQuery').returns('void');
       const mapFn = () => {