ts-async-iterable-queue - npm Package Compare versions

Comparing version 1.1.0 to 1.2.0

dist/lib/createAsyncQueue.js

@@ -49,6 +49,6 @@ "use strict";
             var f = resultsWaitingForResolvers.dequeue();
-            f(pr.resolve);
+            f.resolve(pr);
         }
         else {
-            pendingResolvers.enqueue(pr.resolve);
+            pendingResolvers.enqueue(pr);
         }
@@ -80,3 +80,3 @@ return pr.promise;
                 pr = createPromiseResolver_1.createPromiseResolver();
-                resultsWaitingForResolvers.enqueue(pr.resolve);
+                resultsWaitingForResolvers.enqueue(pr);
                 return [2 /*return*/, pr.promise];
@@ -94,3 +94,3 @@ }
                     resolveResult = _a.sent();
-                    resolveResult({ value: value, done: false });
+                    resolveResult.resolve({ value: value, done: false });
                     return [2 /*return*/];
@@ -107,3 +107,3 @@ }
                     resolveResult = _a.sent();
-                    resolveResult({ done: true });
+                    resolveResult.resolve({ done: true });
                     return [2 /*return*/];
@@ -113,2 +113,14 @@ }
     }); };
+    var error = function (reason) { return __awaiter(_this, void 0, void 0, function () {
+        var resolveResult;
+        return __generator(this, function (_a) {
+            switch (_a.label) {
+                case 0: return [4 /*yield*/, getNextResultResolver()];
+                case 1:
+                    resolveResult = _a.sent();
+                    resolveResult.reject(reason);
+                    return [2 /*return*/];
+            }
+        });
+    }); };
     return _a = {},
@@ -122,2 +134,3 @@ _a[Symbol.asyncIterator] = function () {
         _a.complete = complete,
+        _a.error = error,
         _a;
@@ -124,0 +137,0 @@ }

dist/lib/createQueue.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-function createQueue() {
-    var trimLimit = 10000;
+function createQueue(trimLimit) {
+    if (trimLimit === void 0) { trimLimit = 10000; }
     var store = [];
@@ -6,0 +6,0 @@ var front = 0;

dist/lib/ts-async-iterable-queue.js

@@ -12,2 +12,4 @@ "use strict";
 exports.createQueue = createQueue_1.createQueue;
+var createPushAsyncIterable_1 = require("./createPushAsyncIterable");
+exports.createPushAsyncIterable = createPushAsyncIterable_1.createPushAsyncIterable;
 //# sourceMappingURL=ts-async-iterable-queue.js.map

dist/ts-async-iterable-queue.es5.js

@@ -53,2 +53,37 @@ /*! *****************************************************************************
 
+function __values(o) {
+    var m = typeof Symbol === "function" && o[Symbol.iterator], i = 0;
+    if (m) return m.call(o);
+    return {
+        next: function () {
+            if (o && i >= o.length) o = void 0;
+            return { value: o && o[i++], done: !o };
+        }
+    };
+}
+
+function __await(v) {
+    return this instanceof __await ? (this.v = v, this) : new __await(v);
+}
+
+function __asyncGenerator(thisArg, _arguments, generator) {
+    if (!Symbol.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
+    var g = generator.apply(thisArg, _arguments || []), i, q = [];
+    return i = {}, verb("next"), verb("throw"), verb("return"), i[Symbol.asyncIterator] = function () { return this; }, i;
+    function verb(n) { if (g[n]) i[n] = function (v) { return new Promise(function (a, b) { q.push([n, v, a, b]) > 1 || resume(n, v); }); }; }
+    function resume(n, v) { try { step(g[n](v)); } catch (e) { settle(q[0][3], e); } }
+    function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r); }
+    function fulfill(value) { resume("next", value); }
+    function reject(value) { resume("throw", value); }
+    function settle(f, v) { if (f(v), q.shift(), q.length) resume(q[0][0], q[0][1]); }
+}
+
+function __asyncValues(o) {
+    if (!Symbol.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
+    var m = o[Symbol.asyncIterator], i;
+    return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : o[Symbol.iterator](), i = {}, verb("next"), verb("throw"), verb("return"), i[Symbol.asyncIterator] = function () { return this; }, i);
+    function verb(n) { i[n] = o[n] && function (v) { return new Promise(function (resolve, reject) { v = o[n](v), settle(resolve, reject, v.done, v.value); }); }; }
+    function settle(resolve, reject, d, v) { Promise.resolve(v).then(function(v) { resolve({ value: v, done: d }); }, reject); }
+}
+
 var createPromiseResolver = function () {
@@ -68,4 +103,4 @@ var resolve = null;
 
-function createQueue() {
-    var trimLimit = 10000;
+function createQueue(trimLimit) {
+    if (trimLimit === void 0) { trimLimit = 10000; }
     var store = [];
@@ -110,6 +145,6 @@ var front = 0;
             var f = resultsWaitingForResolvers.dequeue();
-            f(pr.resolve);
+            f.resolve(pr);
         }
         else {
-            pendingResolvers.enqueue(pr.resolve);
+            pendingResolvers.enqueue(pr);
         }
@@ -141,3 +176,3 @@ return pr.promise;
                 pr = createPromiseResolver();
-                resultsWaitingForResolvers.enqueue(pr.resolve);
+                resultsWaitingForResolvers.enqueue(pr);
                 return [2 /*return*/, pr.promise];
@@ -155,3 +190,3 @@ }
                     resolveResult = _a.sent();
-                    resolveResult({ value: value, done: false });
+                    resolveResult.resolve({ value: value, done: false });
                     return [2 /*return*/];
@@ -168,3 +203,3 @@ }
                     resolveResult = _a.sent();
-                    resolveResult({ done: true });
+                    resolveResult.resolve({ done: true });
                     return [2 /*return*/];
@@ -174,2 +209,14 @@ }
     }); };
+    var error = function (reason) { return __awaiter(_this, void 0, void 0, function () {
+        var resolveResult;
+        return __generator(this, function (_a) {
+            switch (_a.label) {
+                case 0: return [4 /*yield*/, getNextResultResolver()];
+                case 1:
+                    resolveResult = _a.sent();
+                    resolveResult.reject(reason);
+                    return [2 /*return*/];
+            }
+        });
+    }); };
     return _a = {},
@@ -183,5 +230,60 @@ _a[Symbol.asyncIterator] = function () {
         _a.complete = complete,
+        _a.error = error,
         _a;
 }
 
+function createPushAsyncIterable(subscriber) {
+    return __asyncGenerator(this, arguments, function createPushAsyncIterable_1() {
+        var e_1, _a, q, unsubscriptions, q_1, q_1_1, x, e_1_1;
+        return __generator(this, function (_b) {
+            switch (_b.label) {
+                case 0:
+                    q = createAsyncQueue();
+                    unsubscriptions = [];
+                    subscriber(q.enqueue, q.complete, q.error, function (handler) { return unsubscriptions.push(handler); });
+                    _b.label = 1;
+                case 1:
+                    _b.trys.push([1, , 16, 17]);
+                    _b.label = 2;
+                case 2:
+                    _b.trys.push([2, 9, 10, 15]);
+                    q_1 = __asyncValues(q);
+                    _b.label = 3;
+                case 3: return [4 /*yield*/, __await(q_1.next())];
+                case 4:
+                    if (!(q_1_1 = _b.sent(), !q_1_1.done)) return [3 /*break*/, 8];
+                    x = q_1_1.value;
+                    return [4 /*yield*/, __await(x)];
+                case 5: return [4 /*yield*/, _b.sent()];
+                case 6:
+                    _b.sent();
+                    _b.label = 7;
+                case 7: return [3 /*break*/, 3];
+                case 8: return [3 /*break*/, 15];
+                case 9:
+                    e_1_1 = _b.sent();
+                    e_1 = { error: e_1_1 };
+                    return [3 /*break*/, 15];
+                case 10:
+                    _b.trys.push([10, , 13, 14]);
+                    if (!(q_1_1 && !q_1_1.done && (_a = q_1.return))) return [3 /*break*/, 12];
+                    return [4 /*yield*/, __await(_a.call(q_1))];
+                case 11:
+                    _b.sent();
+                    _b.label = 12;
+                case 12: return [3 /*break*/, 14];
+                case 13:
+                    if (e_1) throw e_1.error;
+                    return [7 /*endfinally*/];
+                case 14: return [7 /*endfinally*/];
+                case 15: return [3 /*break*/, 17];
+                case 16:
+                    unsubscriptions.forEach(function (f) { return f(); });
+                    return [7 /*endfinally*/];
+                case 17: return [2 /*return*/];
+            }
+        });
+    });
+}
+
 /* istanbul ignore if */
@@ -193,3 +295,3 @@ if (!Symbol.asyncIterator) {
 
-export { createAsyncQueue, createQueue };
+export { createAsyncQueue, createPushAsyncIterable, createQueue };
 //# sourceMappingURL=ts-async-iterable-queue.es5.js.map

dist/ts-async-iterable-queue.umd.js

@@ -59,2 +59,37 @@ (function (global, factory) {
 
+    function __values(o) {
+        var m = typeof Symbol === "function" && o[Symbol.iterator], i = 0;
+        if (m) return m.call(o);
+        return {
+            next: function () {
+                if (o && i >= o.length) o = void 0;
+                return { value: o && o[i++], done: !o };
+            }
+        };
+    }
+
+    function __await(v) {
+        return this instanceof __await ? (this.v = v, this) : new __await(v);
+    }
+
+    function __asyncGenerator(thisArg, _arguments, generator) {
+        if (!Symbol.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
+        var g = generator.apply(thisArg, _arguments || []), i, q = [];
+        return i = {}, verb("next"), verb("throw"), verb("return"), i[Symbol.asyncIterator] = function () { return this; }, i;
+        function verb(n) { if (g[n]) i[n] = function (v) { return new Promise(function (a, b) { q.push([n, v, a, b]) > 1 || resume(n, v); }); }; }
+        function resume(n, v) { try { step(g[n](v)); } catch (e) { settle(q[0][3], e); } }
+        function step(r) { r.value instanceof __await ? Promise.resolve(r.value.v).then(fulfill, reject) : settle(q[0][2], r); }
+        function fulfill(value) { resume("next", value); }
+        function reject(value) { resume("throw", value); }
+        function settle(f, v) { if (f(v), q.shift(), q.length) resume(q[0][0], q[0][1]); }
+    }
+
+    function __asyncValues(o) {
+        if (!Symbol.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
+        var m = o[Symbol.asyncIterator], i;
+        return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : o[Symbol.iterator](), i = {}, verb("next"), verb("throw"), verb("return"), i[Symbol.asyncIterator] = function () { return this; }, i);
+        function verb(n) { i[n] = o[n] && function (v) { return new Promise(function (resolve, reject) { v = o[n](v), settle(resolve, reject, v.done, v.value); }); }; }
+        function settle(resolve, reject, d, v) { Promise.resolve(v).then(function(v) { resolve({ value: v, done: d }); }, reject); }
+    }
+
     var createPromiseResolver = function () {
@@ -74,4 +109,4 @@ var resolve = null;
 
-    function createQueue() {
-        var trimLimit = 10000;
+    function createQueue(trimLimit) {
+        if (trimLimit === void 0) { trimLimit = 10000; }
         var store = [];
@@ -116,6 +151,6 @@ var front = 0;
                 var f = resultsWaitingForResolvers.dequeue();
-                f(pr.resolve);
+                f.resolve(pr);
             }
             else {
-                pendingResolvers.enqueue(pr.resolve);
+                pendingResolvers.enqueue(pr);
             }
@@ -147,3 +182,3 @@ return pr.promise;
                     pr = createPromiseResolver();
-                    resultsWaitingForResolvers.enqueue(pr.resolve);
+                    resultsWaitingForResolvers.enqueue(pr);
                     return [2 /*return*/, pr.promise];
@@ -161,3 +196,3 @@ }
                         resolveResult = _a.sent();
-                        resolveResult({ value: value, done: false });
+                        resolveResult.resolve({ value: value, done: false });
                         return [2 /*return*/];
@@ -174,3 +209,3 @@ }
                         resolveResult = _a.sent();
-                        resolveResult({ done: true });
+                        resolveResult.resolve({ done: true });
                         return [2 /*return*/];
@@ -180,2 +215,14 @@ }
         }); };
+        var error = function (reason) { return __awaiter(_this, void 0, void 0, function () {
+            var resolveResult;
+            return __generator(this, function (_a) {
+                switch (_a.label) {
+                    case 0: return [4 /*yield*/, getNextResultResolver()];
+                    case 1:
+                        resolveResult = _a.sent();
+                        resolveResult.reject(reason);
+                        return [2 /*return*/];
+                }
+            });
+        }); };
         return _a = {},
@@ -189,5 +236,60 @@ _a[Symbol.asyncIterator] = function () {
             _a.complete = complete,
+            _a.error = error,
             _a;
     }
 
+    function createPushAsyncIterable(subscriber) {
+        return __asyncGenerator(this, arguments, function createPushAsyncIterable_1() {
+            var e_1, _a, q, unsubscriptions, q_1, q_1_1, x, e_1_1;
+            return __generator(this, function (_b) {
+                switch (_b.label) {
+                    case 0:
+                        q = createAsyncQueue();
+                        unsubscriptions = [];
+                        subscriber(q.enqueue, q.complete, q.error, function (handler) { return unsubscriptions.push(handler); });
+                        _b.label = 1;
+                    case 1:
+                        _b.trys.push([1, , 16, 17]);
+                        _b.label = 2;
+                    case 2:
+                        _b.trys.push([2, 9, 10, 15]);
+                        q_1 = __asyncValues(q);
+                        _b.label = 3;
+                    case 3: return [4 /*yield*/, __await(q_1.next())];
+                    case 4:
+                        if (!(q_1_1 = _b.sent(), !q_1_1.done)) return [3 /*break*/, 8];
+                        x = q_1_1.value;
+                        return [4 /*yield*/, __await(x)];
+                    case 5: return [4 /*yield*/, _b.sent()];
+                    case 6:
+                        _b.sent();
+                        _b.label = 7;
+                    case 7: return [3 /*break*/, 3];
+                    case 8: return [3 /*break*/, 15];
+                    case 9:
+                        e_1_1 = _b.sent();
+                        e_1 = { error: e_1_1 };
+                        return [3 /*break*/, 15];
+                    case 10:
+                        _b.trys.push([10, , 13, 14]);
+                        if (!(q_1_1 && !q_1_1.done && (_a = q_1.return))) return [3 /*break*/, 12];
+                        return [4 /*yield*/, __await(_a.call(q_1))];
+                    case 11:
+                        _b.sent();
+                        _b.label = 12;
+                    case 12: return [3 /*break*/, 14];
+                    case 13:
+                        if (e_1) throw e_1.error;
+                        return [7 /*endfinally*/];
+                    case 14: return [7 /*endfinally*/];
+                    case 15: return [3 /*break*/, 17];
+                    case 16:
+                        unsubscriptions.forEach(function (f) { return f(); });
+                        return [7 /*endfinally*/];
+                    case 17: return [2 /*return*/];
+                }
+            });
+        });
+    }
+
     /* istanbul ignore if */
@@ -200,2 +302,3 @@ if (!Symbol.asyncIterator) {
     exports.createAsyncQueue = createAsyncQueue;
+    exports.createPushAsyncIterable = createPushAsyncIterable;
     exports.createQueue = createQueue;
@@ -202,0 +305,0 @@

dist/types/AsyncIterableQueue.d.ts

@@ -5,2 +5,3 @@ export interface AsyncIterableQueue<T> extends AsyncIterableIterator<T> {
     complete(): void;
+    error(reason: any): void;
 }

dist/types/createPromiseResolver.d.ts

@@ -1,5 +0,2 @@
-export declare const createPromiseResolver: <T>() => {
-    resolve: (v: T) => void;
-    reject: (reason: any) => void;
-    promise: Promise<T>;
-};
+import { PromiseResolver } from './PromiseResolver';
+export declare const createPromiseResolver: <T = void>() => PromiseResolver<T>;

dist/types/createQueue.d.ts

@@ -6,2 +6,2 @@ export interface Queue<T> {
 }
-export declare function createQueue<T>(): Queue<T>;
+export declare function createQueue<T>(trimLimit?: number): Queue<T>;

dist/types/ts-async-iterable-queue.d.ts

 export { createAsyncQueue } from './createAsyncQueue';
 export { createQueue } from './createQueue';
+export { createPushAsyncIterable } from './createPushAsyncIterable';

package.json

 {
   "name": "ts-async-iterable-queue",
-  "version": "1.1.0",
+  "version": "1.2.0",
   "description": "",
@@ -34,3 +34,2 @@ "keywords": [],
     "semantic-release-prepare": "ts-node tools/semantic-release-prepare",
-    "precommit": "lint-staged",
     "travis-deploy-once": "travis-deploy-once"
@@ -121,3 +120,8 @@ },
   },
-  "dependencies": {}
+  "dependencies": {},
+  "husky": {
+    "hooks": {
+      "pre-commit": "lint-staged"
+    }
+  }
 }

No alert changes

Improved metrics

Total package byte prevSize

67098

increased by46.66%

Lines of code

883

increased by54.91%

No dependency changes