apollo-link-queue - npm Package Compare versions

Comparing version 2.0.1 to 2.1.0

build/dist/QueueLink.js

@@ -38,5 +38,9 @@ "use strict";
         }
+        if (operation.getContext().skipQueue) {
+            return forward(operation);
+        }
         return new apollo_link_1.Observable(function (observer) {
-            _this.enqueue({ operation: operation, forward: forward, observer: observer });
-            return function () { return _this.cancelOperation({ operation: operation, forward: forward, observer: observer }); };
+            var operationEntry = { operation: operation, forward: forward, observer: observer };
+            _this.enqueue(operationEntry);
+            return function () { return _this.cancelOperation(operationEntry); };
         });
@@ -43,0 +47,0 @@ };

package.json

 {
   "name": "apollo-link-queue",
-  "version": "2.0.1",
+  "version": "2.1.0",
   "description": "A link to queue requests when a certain condition is met (eg. device is offline)",
@@ -5,0 +5,0 @@ "dependencies": {

src/QueueLink.test.ts

@@ -52,2 +52,23 @@ import QueueLink from './QueueLink';
     });
+    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', () => {
@@ -96,3 +117,3 @@ const testError = new Error('Hello darkness my old friend');
         const observable = execute(link, op);
-        const subscriber = observable.subscribe(() => {})
+        const subscriber = observable.subscribe(() => { /* do nothing */ });
         subscriber.unsubscribe();
@@ -99,0 +120,0 @@ onOffLink.open();

src/QueueLink.ts

@@ -37,2 +37,5 @@ import {
         }
+        if (operation.getContext().skipQueue) {
+            return forward(operation);
+        }
         return new Observable(observer => {
@@ -39,0 +42,0 @@ const operationEntry = { operation, forward, observer };

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

240047

increased by0.44%

Lines of code

414

increased by7.25%

No dependency changes