diff --git a/ts/00_commitinfo_data.ts b/ts/00_commitinfo_data.ts
index 84f4e65..1e5c91a 100644
--- a/ts/00_commitinfo_data.ts
+++ b/ts/00_commitinfo_data.ts
@@ -3,6 +3,6 @@
  */
 export const commitinfo = {
   name: '@push.rocks/lik',
-  version: '6.0.8',
+  version: '6.0.9',
   description: 'light little helpers for node'
 }
diff --git a/ts/backpressuredarray.ts b/ts/backpressuredarray.ts
index 66baff9..6a6d96b 100644
--- a/ts/backpressuredarray.ts
+++ b/ts/backpressuredarray.ts
@@ -3,19 +3,18 @@ import * as plugins from './lik.plugins.js';
 export class BackpressuredArray<T> {
   private data: T[];
   private highWaterMark: number;
-  public hasSpace: plugins.smartrx.rxjs.Subject<void>;
+  public hasSpace = new plugins.smartrx.rxjs.Subject<'hasSpace'>();
 
   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();
+      this.hasSpace.next('hasSpace');
     }
     return spaceAvailable
   }
@@ -23,7 +22,7 @@ export class BackpressuredArray<T> {
   shift(): T | undefined {
     const item = this.data.shift();
     if (this.checkSpaceAvailable()) {
-      this.hasSpace.next();
+      this.hasSpace.next('hasSpace');
     }
     return item;
   }