push.rocks/taskbuffer
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
2020-09-02 13:04:52 +00:00
parent ddc9a77fe2
commit 09936fda56
4 changed files with 27 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
ts/taskbuffer.classes.taskdebounced.ts
View File

@ -15,11 +15,13 @@ export class TaskDebounced<T = unknown> extends Task {
name: optionsArg.name,
taskFunction: async (x: T) => {
this._observableIntake.push(x);
}
},
});
this.taskFunction = optionsArg.taskFunction;
this._observableIntake.observable.pipe(plugins.smartrx.rxjs.ops.debounceTime(optionsArg.debounceTimeInMillis)).subscribe((x) => {
this.taskFunction(x);
});
this._observableIntake.observable
.pipe(plugins.smartrx.rxjs.ops.debounceTime(optionsArg.debounceTimeInMillis))
.subscribe((x) => {
this.taskFunction(x);
});
}
}
}