Add possibility to skip the queue

helfer · Jul 11, 2018 · 4583b2f · 4583b2f
1 parent 0850ef9
commit 4583b2f
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 0 deletions.
diff --git a/src/QueueLink.test.ts b/src/QueueLink.test.ts
@@ -49,6 +49,27 @@ describe('OnOffLink', () => {
             jest.runAllTimers();
         });
     });
+    it('skips the queue when asked to', () => {
+        const opWithSkipQueue: GraphQLRequest = {
+            query: gql`{ hello }`,
+            context: {
+                skipQueue: true,
+            },
+        };
+        onOffLink.close();
+        return new Promise((resolve, reject) => {
+            execute(link, opWithSkipQueue).subscribe({
+                next: (data) => undefined,
+                error: (error) => reject(error),
+                complete: () => {
+                    expect(testLink.operations.length).toBe(1);
+                    expect(testLink.operations[0].query).toEqual(op.query);
+                    resolve();
+                },
+            });
+            jest.runAllTimers();
+        });
+    });
     it('passes through errors', () => {
         const testError = new Error('Hello darkness my old friend');
         const opWithError: GraphQLRequest = {

diff --git a/src/QueueLink.ts b/src/QueueLink.ts
@@ -34,6 +34,9 @@ export default class QueueLink extends ApolloLink {
         if (this.isOpen) {
             return forward(operation);
         }
+        if (operation.getContext().skipQueue) {
+            return forward(operation);
+        }
         return new Observable(observer => {
             const operationEntry = { operation, forward, observer };
             this.enqueue(operationEntry);