Class: TaskScheduler

• new TaskScheduler(options)

• new TaskScheduler(options?)

▸ abort(): TaskScheduler

Cancel all tasks

TaskScheduler

this

▸ abortTask(id): TaskScheduler

Abort tasks by id

TaskScheduler

this

▸ addTask(task, options?): ITask

Add a new task to queue

Example

// add a task
scheduler.addTask((resolve, reject, cancel) => {
resolve();
});

Example

// add a task and use it as a promise
scheduler.addTask((resolve, reject, cancel) => {
resolve();
}).toPromise().then((data) => {
...
}).catch((error) => {
...
});

Example

// handle cancellation in the task
scheduler.addTask((resolve, reject, cancel) => {
// Handle cancellation
const AbortedErrorCode = 'Aborted';
cancel.setErrorHandler(() => {
reject(new Error(AbortedErrorCode));
});
});

ITask

task created task

▸ getLastTaskId(): number

Return id of the last task

number

▸ getNumberOfParallelTasks(): number

Gets number of running in parallel tasks

number

count number of parallel tasks

▸ isEmpty(): boolean

Return true if there are no tasks in the queue

boolean

▸ setNumberOfParallelTasks(count): TaskScheduler

Sets number of running in parallel tasks

TaskScheduler

this