test(RxObservableQuery): chaining (#28)

kamilkisiela · Feb 3, 2017 · 3b494a7 · 3b494a7
1 parent 66c011a
commit 3b494a7
Showing 1 changed file with 24 additions and 0 deletions.
diff --git a/tests/RxObservableQuery.ts b/tests/RxObservableQuery.ts
@@ -7,6 +7,7 @@ import { RxObservableQuery } from '../src/RxObservableQuery';
 import { ObservableQueryRef } from '../src/utils/ObservableQueryRef';
 
 import 'rxjs/add/operator/map';
+import 'rxjs/add/operator/do';
 
 describe('RxObservableQuery', () => {
   let obsQuery: ObservableQuery<any>;
@@ -65,6 +66,29 @@ describe('RxObservableQuery', () => {
         },
       });
     });
+
+    it('should be chainable', (done: MochaDone) => {
+      const counter = { calls: 0 };
+
+      function justDoIt() {
+        counter.calls++;
+      }
+
+      rxObsQuery
+      .do(justDoIt)
+      .do(justDoIt)
+      .do(justDoIt)
+      .subscribe({
+        next(result) {
+          assert.deepEqual(result.data, heroes.data);
+          assert.equal(counter.calls, 3);
+          done();
+        },
+        error() {
+          done(new Error('should not be called'));
+        },
+      });
+    });
   });
 
   describe('apollo-specific', () => {