node-apparatus - npm Package Compare versions

Comparing version 0.1.11 to 0.1.12

dist/src/index.d.ts

@@ -6,4 +6,9 @@ import { InjectableConstructor } from "./injectable-constructor/injectable-constructor.js";
 import { SortedMap } from "./sorted-map/sorted-map.js";
-import { SequentialInvocationQueue } from "./sequential-invocation-queue/sequential-invocation-queue";
-import { SpinWaitLock } from "./spin-wait-lock/spin-wait-lock";
-export { kWayMerge, StatefulRecipient, StatefulProxyManager, InjectableConstructor, SortedMap, SpinWaitLock, SequentialInvocationQueue };
+import { SequentialInvocationQueue, Serializable } from "./sequential-invocation-queue/sequential-invocation-queue.js";
+import { SpinWaitLock } from "./spin-wait-lock/spin-wait-lock.js";
+import { DistributedWindowIdentity } from "./distributed-window/distributed-window-identity.js";
+import { DistributedTimeWindow } from "./distributed-window/distributed-time-window.js";
+import { DistributedWindow } from "./distributed-window/distributed-window.js";
+import { IAccumulator } from "./distributed-window/i-accumulator.js";
+import { IDistributedSortedSet } from "./distributed-window/i-distributed-sorted-set.js";
+export { kWayMerge, StatefulRecipient, StatefulProxyManager, InjectableConstructor, SortedMap, SpinWaitLock, SequentialInvocationQueue, Serializable, DistributedWindowIdentity, DistributedTimeWindow, DistributedWindow, IAccumulator, IDistributedSortedSet };

dist/src/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.SequentialInvocationQueue = exports.SpinWaitLock = exports.SortedMap = exports.InjectableConstructor = exports.StatefulProxyManager = exports.StatefulRecipient = exports.kWayMerge = void 0;
+exports.DistributedWindow = exports.DistributedTimeWindow = exports.DistributedWindowIdentity = exports.SequentialInvocationQueue = exports.SpinWaitLock = exports.SortedMap = exports.InjectableConstructor = exports.StatefulProxyManager = exports.StatefulRecipient = exports.kWayMerge = void 0;
 const injectable_constructor_js_1 = require("./injectable-constructor/injectable-constructor.js");
@@ -14,6 +14,12 @@ Object.defineProperty(exports, "InjectableConstructor", { enumerable: true, get: function () { return injectable_constructor_js_1.InjectableConstructor; } });
 Object.defineProperty(exports, "SortedMap", { enumerable: true, get: function () { return sorted_map_js_1.SortedMap; } });
-const sequential_invocation_queue_1 = require("./sequential-invocation-queue/sequential-invocation-queue");
-Object.defineProperty(exports, "SequentialInvocationQueue", { enumerable: true, get: function () { return sequential_invocation_queue_1.SequentialInvocationQueue; } });
-const spin_wait_lock_1 = require("./spin-wait-lock/spin-wait-lock");
-Object.defineProperty(exports, "SpinWaitLock", { enumerable: true, get: function () { return spin_wait_lock_1.SpinWaitLock; } });
+const sequential_invocation_queue_js_1 = require("./sequential-invocation-queue/sequential-invocation-queue.js");
+Object.defineProperty(exports, "SequentialInvocationQueue", { enumerable: true, get: function () { return sequential_invocation_queue_js_1.SequentialInvocationQueue; } });
+const spin_wait_lock_js_1 = require("./spin-wait-lock/spin-wait-lock.js");
+Object.defineProperty(exports, "SpinWaitLock", { enumerable: true, get: function () { return spin_wait_lock_js_1.SpinWaitLock; } });
+const distributed_window_identity_js_1 = require("./distributed-window/distributed-window-identity.js");
+Object.defineProperty(exports, "DistributedWindowIdentity", { enumerable: true, get: function () { return distributed_window_identity_js_1.DistributedWindowIdentity; } });
+const distributed_time_window_js_1 = require("./distributed-window/distributed-time-window.js");
+Object.defineProperty(exports, "DistributedTimeWindow", { enumerable: true, get: function () { return distributed_time_window_js_1.DistributedTimeWindow; } });
+const distributed_window_js_1 = require("./distributed-window/distributed-window.js");
+Object.defineProperty(exports, "DistributedWindow", { enumerable: true, get: function () { return distributed_window_js_1.DistributedWindow; } });
 //# sourceMappingURL=index.js.map

dist/src/sequential-invocation-queue/sequential-invocation-queue.d.ts

 import { SpinWaitLock } from "../spin-wait-lock/spin-wait-lock";
-type stringable = string | string[];
-type numberable = number | number[];
-export type serializable = stringable | numberable | Record<string | number, stringable | numberable>;
+/**
+ * A type that can be serialized.
+ */
+export type Serializable = string | number | boolean | Serializable[] | {
+    [key: string]: Serializable;
+};
 export interface InvocationResult<Treturn> {
@@ -12,3 +15,3 @@ result?: Treturn;
  */
-export declare class SequentialInvocationQueue<Targs extends serializable, Treturn extends serializable | void> {
+export declare class SequentialInvocationQueue<Targs extends Serializable, Treturn extends Serializable | void> {
     private readonly lock;
@@ -60,2 +63,1 @@ private readonly invocationFunction;
 }
-export {};

dist/src/sorted-map/sorted-map.d.ts

@@ -37,2 +37,14 @@ /**
     /**
+     * Check if a key exists in the map.
+     * @param key The key of the element.
+     * @returns True if the key exists in the map, false otherwise.
+    */
+    has(key: string): boolean;
+    /**
+     * Delete a key from the map.
+     * @param key The key of the element.
+     * @returns True if the key was deleted, false otherwise.
+    */
+    delete(key: string): boolean;
+    /**
      * Clears the map.
@@ -39,0 +51,0 @@ */

dist/src/sorted-map/sorted-map.js

@@ -65,2 +65,18 @@ "use strict";
     /**
+     * Check if a key exists in the map.
+     * @param key The key of the element.
+     * @returns True if the key exists in the map, false otherwise.
+    */
+    has(key) {
+        return this.map.has(key) && this.sortedKeys.has(key);
+    }
+    /**
+     * Delete a key from the map.
+     * @param key The key of the element.
+     * @returns True if the key was deleted, false otherwise.
+    */
+    delete(key) {
+        return this.map.delete(key) && this.sortedKeys.delete(key);
+    }
+    /**
      * Clears the map.
@@ -67,0 +83,0 @@ */

package.json

 {
   "name": "node-apparatus",
-  "version": "0.1.11",
+  "version": "0.1.12",
   "description": "A mix of common components needed for awesome node experience",
@@ -5,0 +5,0 @@ "main": "dist/src/index.js",

README.md

@@ -0,0 +0,0 @@ # node-apparatus

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

107342

increased by66.5%

Number of package files

47

increased by56.67%

Lines of code

1201

increased by56.38%

No dependency changes