Compare commits

..

4 Commits

Author SHA1 Message Date
7d57fcf07e 2.1.8 2020-09-02 15:26:46 +00:00
eb9ae2fa71 fix(core): update 2020-09-02 15:26:45 +00:00
5fe60c6e50 2.1.7 2020-09-02 13:46:27 +00:00
6f811b4ab5 fix(core): update 2020-09-02 13:46:26 +00:00
4 changed files with 14 additions and 13 deletions

18
package-lock.json generated
View File

@ -1,6 +1,6 @@
{ {
"name": "@pushrocks/taskbuffer", "name": "@pushrocks/taskbuffer",
"version": "2.1.6", "version": "2.1.8",
"lockfileVersion": 1, "lockfileVersion": 1,
"requires": true, "requires": true,
"dependencies": { "dependencies": {
@ -1973,15 +1973,15 @@
} }
}, },
"@pushrocks/smarttime": { "@pushrocks/smarttime": {
"version": "3.0.24", "version": "3.0.26",
"resolved": "https://verdaccio.lossless.one/@pushrocks%2fsmarttime/-/smarttime-3.0.24.tgz", "resolved": "https://verdaccio.lossless.one/@pushrocks%2fsmarttime/-/smarttime-3.0.26.tgz",
"integrity": "sha512-c/n0Y3CUnVNa3TnuXZ5aRc0bWj4RX7+XSjPes1J4HidU1yBOd9UOt6l08W8aPH5jMjT9Ei2jH0GsheaTGoVEYA==", "integrity": "sha512-JzRAYR7xPvNPPFj2euU8jmnAc+1wwDCB/Or7aZ7eADP9XXV9xCXpYXw6KcCYC/UQ8HqXLunbS+371eZcU2dJaA==",
"requires": { "requires": {
"@pushrocks/lik": "^4.0.13", "@pushrocks/lik": "^4.0.17",
"@pushrocks/smartdelay": "^2.0.10", "@pushrocks/smartdelay": "^2.0.10",
"@pushrocks/smartpromise": "^3.0.2", "@pushrocks/smartpromise": "^3.0.2",
"croner": "^1.1.23", "croner": "^1.1.23",
"dayjs": "^1.8.29", "dayjs": "^1.8.35",
"is-nan": "^1.3.0" "is-nan": "^1.3.0"
} }
}, },
@ -4185,9 +4185,9 @@
} }
}, },
"dayjs": { "dayjs": {
"version": "1.8.29", "version": "1.8.35",
"resolved": "https://verdaccio.lossless.one/dayjs/-/dayjs-1.8.29.tgz", "resolved": "https://verdaccio.lossless.one/dayjs/-/dayjs-1.8.35.tgz",
"integrity": "sha512-Vm6teig8ZWK7rH/lxzVGxZJCljPdmUr6q/3f4fr5F0VWNGVkZEjZOQJsAN8hUHUqn+NK4XHNEpJZS1MwLyDcLw==" "integrity": "sha512-isAbIEenO4ilm6f8cpqvgjZCsuerDAz2Kb7ri201AiNn58aqXuaLJEnCtfIMdCvERZHNGRY5lDMTr/jdAnKSWQ=="
}, },
"deasync": { "deasync": {
"version": "0.1.20", "version": "0.1.20",

View File

@ -1,6 +1,6 @@
{ {
"name": "@pushrocks/taskbuffer", "name": "@pushrocks/taskbuffer",
"version": "2.1.6", "version": "2.1.8",
"private": false, "private": false,
"description": "flexible task management. TypeScript ready!", "description": "flexible task management. TypeScript ready!",
"main": "dist_ts/index.js", "main": "dist_ts/index.js",
@ -32,7 +32,7 @@
"@pushrocks/smartlog": "^2.0.36", "@pushrocks/smartlog": "^2.0.36",
"@pushrocks/smartpromise": "^3.0.6", "@pushrocks/smartpromise": "^3.0.6",
"@pushrocks/smartrx": "^2.0.18", "@pushrocks/smartrx": "^2.0.18",
"@pushrocks/smarttime": "^3.0.24", "@pushrocks/smarttime": "^3.0.26",
"@types/cron": "^1.7.2" "@types/cron": "^1.7.2"
}, },
"devDependencies": { "devDependencies": {

View File

@ -200,6 +200,7 @@ export class Task {
/** /**
* trigger task unbuffered. * trigger task unbuffered.
* will actually run the task, not considering any buffered limits.
*/ */
public triggerUnBuffered(x?): Promise<any> { public triggerUnBuffered(x?): Promise<any> {
return Task.runTask(this, { x: x }); return Task.runTask(this, { x: x });
@ -207,6 +208,7 @@ export class Task {
/** /**
* trigger task buffered. * trigger task buffered.
* will simply call task.trigger(), which respects buffering by default
*/ */
public triggerBuffered(x?): Promise<any> { public triggerBuffered(x?): Promise<any> {
return this.bufferRunner.trigger(x); return this.bufferRunner.trigger(x);

View File

@ -44,8 +44,7 @@ export class TaskManager {
*/ */
public addAndScheduleTask(taskArg: Task, cronStringArg: string) { public addAndScheduleTask(taskArg: Task, cronStringArg: string) {
this.addTask(taskArg); this.addTask(taskArg);
const taskName = taskArg.name; this.scheduleTaskByName(taskArg.name, cronStringArg);
this.scheduleTaskByName(taskName, cronStringArg);
} }
/** /**