push.rocks/lik
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(core): update

Browse Source
This commit is contained in:
Philipp Kunz 2023-11-13 16:27:04 +01:00
parent 326030456f
commit dfe973f5d8
2 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ts/00_commitinfo_data.ts
View File

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

7
ts/backpressuredarray.ts
View File

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