6.0.14

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@push.rocks/lik",
-  "version": "6.0.7",
+  "version": "6.0.14",
   "private": false,
   "description": "light little helpers for node",
   "main": "dist_ts/index.js",

ts/00_commitinfo_data.ts

@@ -3,6 +3,6 @@
  */
 export const commitinfo = {
   name: '@push.rocks/lik',
-  version: '6.0.7',
+  version: '6.0.14',
   description: 'light little helpers for node'
 }

ts/backpressuredarray.ts

@@ -1,34 +0,0 @@
-import * as plugins from './lik.plugins.js';
-
-export class BackpressuredArray<T> {
-  private data: T[];
-  private highWaterMark: number;
-  public hasSpace: plugins.smartrx.rxjs.Subject<void>;
-
-  constructor(highWaterMark: number = 16) {
-    this.data = [];
-    this.highWaterMark = highWaterMark;
-    this.hasSpace = new plugins.smartrx.rxjs.Subject<void>();
-  }
-
-  push(item: T): boolean {
-    this.data.push(item);
-    const spaceAvailable = this.checkSpaceAvailable();
-    if (spaceAvailable) {
-      this.hasSpace.next();
-    }
-    return spaceAvailable
-  }
-
-  shift(): T | undefined {
-    const item = this.data.shift();
-    if (this.checkSpaceAvailable()) {
-      this.hasSpace.next();
-    }
-    return item;
-  }
-
-  checkSpaceAvailable(): boolean {
-    return this.data.length < this.highWaterMark;
-  }
-}

ts/classes.asyncexecutionstack.ts

@@ -1,4 +1,4 @@
-import * as plugins from './lik.plugins.js';
+import * as plugins from './classes.plugins.js';
 
 interface IExecutionSlot<T> {
   executionDeferred: plugins.smartpromise.Deferred<T>;

ts/classes.backpressuredarray.ts

@@ -0,0 +1,62 @@
+import * as plugins from './classes.plugins.js';
+
+export class BackpressuredArray<T> {
+  public data: T[];
+  private highWaterMark: number;
+  public hasSpace = new plugins.smartrx.rxjs.Subject<'hasSpace'>();
+  private itemsAvailable = new plugins.smartrx.rxjs.Subject<'itemsAvailable'>();
+
+  constructor(highWaterMark: number = 16) {
+    this.data = [];
+    this.highWaterMark = highWaterMark;
+  }
+
+  push(item: T): boolean {
+    this.data.push(item);
+    this.itemsAvailable.next('itemsAvailable');
+    
+    const spaceAvailable = this.checkSpaceAvailable();
+    if (spaceAvailable) {
+      this.hasSpace.next('hasSpace');
+    }
+    return spaceAvailable;
+  }
+
+  shift(): T | undefined {
+    const item = this.data.shift();
+    if (this.checkSpaceAvailable()) {
+      this.hasSpace.next('hasSpace');
+    }
+    return item;
+  }
+
+  checkSpaceAvailable(): boolean {
+    return this.data.length < this.highWaterMark;
+  }
+
+  waitForSpace(): Promise<void> {
+    return new Promise<void>((resolve) => {
+      if (this.checkSpaceAvailable()) {
+        resolve();
+      } else {
+        const subscription = this.hasSpace.subscribe(() => {
+          subscription.unsubscribe();
+          resolve();
+        });
+      }
+    });
+  }
+
+  waitForItems(): Promise<void> {
+    return new Promise<void>((resolve) => {
+      if (this.data.length > 0) {
+        resolve();
+      } else {
+        const subscription = this.itemsAvailable.subscribe(() => {
+          subscription.unsubscribe();
+          resolve();
+        });
+      }
+    });
+  }
+}

ts/classes.fastmap.ts

@@ -3,7 +3,7 @@ The FastMap has the goal of creating the fastes to use map possible in JS
 
 ============ */
 
-import * as plugins from './lik.plugins.js';
+import * as plugins from './classes.plugins.js';
 
 /**
  * fast map allows for very quick lookups of objects with a unique key

ts/classes.interestmap.interest.ts

@@ -1,6 +1,6 @@
-import * as plugins from './lik.plugins.js';
+import * as plugins from './classes.plugins.js';
 
-import { InterestMap, type IInterestComparisonFunc } from './lik.interestmap.js';
+import { InterestMap, type IInterestComparisonFunc } from './classes.interestmap.js';
 
 export interface IInterestOptions<DTInterestFullfillment> {
   markLostAfterDefault: number;

ts/classes.interestmap.ts

@@ -8,9 +8,9 @@ Subssequent interests will be mapped to the same interest
 which is then is only fullfilled once.
 =========== */
 
-import * as plugins from './lik.plugins.js';
+import * as plugins from './classes.plugins.js';
-import { ObjectMap } from './lik.objectmap.js';
+import { ObjectMap } from './classes.objectmap.js';
-import { Interest } from './lik.interestmap.interest.js';
+import { Interest } from './classes.interestmap.interest.js';
 
 export type IInterestComparisonFunc<T> = (objectArg: T) => string;
 

ts/classes.limitedarray.ts

@@ -1,4 +1,4 @@
-import * as plugins from './lik.plugins.js';
+import * as plugins from './classes.plugins.js';
 
 export class LimitedArray<T> {
   array: T[] = [];

ts/classes.looptracker.ts

@@ -1,6 +1,6 @@
-import * as plugins from './lik.plugins.js';
+import * as plugins from './classes.plugins.js';
 
-import { ObjectMap } from './lik.objectmap.js';
+import { ObjectMap } from './classes.objectmap.js';
 
 export class LoopTracker<T> {
   referenceObjectMap = new ObjectMap<any>();

ts/classes.objectmap.ts

@@ -1,5 +1,5 @@
-import * as plugins from './lik.plugins.js';
+import * as plugins from './classes.plugins.js';
-import { FastMap } from './lik.fastmap.js';
+import { FastMap } from './classes.fastmap.js';
 
 export const uni = (prefix: string = 'uni') => {
   return `${prefix}xxxxxxxxxxx`.replace(/[xy]/g, (c) => {

ts/classes.stringmap.ts

@@ -1,4 +1,4 @@
-import * as plugins from './lik.plugins.js';
+import * as plugins from './classes.plugins.js';
 
 /**
  * allows you to easily keep track of a bunch of strings

ts/classes.timedaggregator.ts

@@ -1,4 +1,4 @@
-import * as plugins from './lik.plugins.js';
+import * as plugins from './classes.plugins.js';
 
 export interface ITimedAggregatorOptions<T> {
   aggregationIntervalInMillis: number;

ts/classes.tree.ts

@@ -1,4 +1,4 @@
-import * as plugins from './lik.plugins.js';
+import * as plugins from './classes.plugins.js';
 
 export class Tree<T> {
   symbolTree: any;

ts/index.ts

@@ -1,11 +1,11 @@
-export * from './lik.asyncexecutionstack.js';
+export * from './classes.asyncexecutionstack.js';
-export * from './backpressuredarray.js';
+export * from './classes.backpressuredarray.js';
-export * from './lik.fastmap.js';
+export * from './classes.fastmap.js';
-export * from './lik.interestmap.js';
+export * from './classes.interestmap.js';
-export * from './lik.interestmap.interest.js';
+export * from './classes.interestmap.interest.js';
-export * from './lik.limitedarray.js';
+export * from './classes.limitedarray.js';
-export * from './lik.looptracker.js';
+export * from './classes.looptracker.js';
-export * from './lik.objectmap.js';
+export * from './classes.objectmap.js';
-export * from './lik.stringmap.js';
+export * from './classes.stringmap.js';
-export * from './lik.timedaggregator.js';
+export * from './classes.timedaggregator.js';
-export * from './lik.tree.js';
+export * from './classes.tree.js';