push.rocks/smartstream
3
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

fix(core): update

Browse Source
This commit is contained in:
Philipp Kunz
2023-11-13 20:34:21 +01:00
parent c77e0f2ba6
commit 28725d1723
2 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
ts/smartstream.classes.smartduplex.ts
View File

@@ -35,7 +35,7 @@ export class SmartDuplex<TInput = any, TOutput = any> extends Duplex {
}
// INSTANCE
private backpressuredArray = new plugins.lik.BackpressuredArray<TOutput>();
private backpressuredArray: plugins.lik.BackpressuredArray<TOutput>;
public options: ISmartDuplexOptions<TInput, TOutput>;
private observableSubscription?: plugins.smartrx.rxjs.Subscription;
private debugLog(messageArg: string) {
@@ -45,8 +45,11 @@ export class SmartDuplex<TInput = any, TOutput = any> extends Duplex {
}
constructor(optionsArg?: ISmartDuplexOptions<TInput, TOutput>) {
super(optionsArg);
super(Object.assign({
highWaterMark: 1,
}, optionsArg));
this.options = optionsArg;
this.backpressuredArray = new plugins.lik.BackpressuredArray<TOutput>(this.options.highWaterMark || 1)
}
public async _read(size: number): Promise<void> {