Restart task

This is the way to create a restartable task.

This will cancel the oldest instance of the task and start a new instance of it. You can also provide a max that will only restart the oldest task instance if the threshold is exceeded.

Usage

To specify a task as restartable, you can either use the dot notation or the options notation.

Dot notation

import { task } from '@sheepdog/vanilla';

const restartTask = task.restart(async () => {
  // your code
});

Options notation

import { task } from '@sheepdog/vanilla';

const restartTask = task(
  async () => {
    // your code
  },
  { kind: 'restart' },
);

Caution

If you invoke perform multiple times in the same microtask, only the last instance will actually run because by the time the function is invoked the previous invocations would’ve been already canceled.

Max concurrency

This is how you can specify the maximum number of concurrent instances. The default is 1, here we’re setting it to 5.

Dot notation

import { task } from '@sheepdog/vanilla';

const restartTask = task.restart(
  async () => {
    // your code
  },
  { max: 5 },
);

Options notation

import { task } from '@sheepdog/vanilla';

const restartTask = task(
  async () => {
    // your code
  },
  { kind: 'restart', max: 5 },
);

The task

The return value of the task function will be an object with getters where you can access state from all the instances running and eventually cancel them with cancelAll.

Task structure Take a look at the Task structure documentation in our Getting started

Passing props

While defining a task, if the function that you pass in has some arguments, those will be required by the perform function (and it will be strongly typed too).

Caution

If you need to pass multiple props you should use an object because the second parameter will always be the SheepdogUtils.

Dot notation

import { task } from '@sheepdog/vanilla';

const restartTask = task.restart(async (id: string) => {
  // your code
});

button.addEventListener('click', () => {
  restartTask.perform('42');
});

Options notation

import { task } from '@sheepdog/vanilla';

const restartTask = task(
  async (id: string) => {
    // your code
  },
  { kind: 'restart' },
);

button.addEventListener('click', () => {
  restartTask.perform('42');
});

Getting the return value

If you return something from your task you can access the return value by awaiting the perform function.

Dot notation

import { task } from '@sheepdog/vanilla';

const restartTask = task.restart(async () => {
  return 42;
});

button.addEventListener('click', () => {
  const number = await restartTask.perform();
  console.log(number); // 42
});

Options notation

import { task } from '@sheepdog/vanilla';

const restartTask = task(
  async () => {
    return 42;
  },
  { kind: 'restart' },
);

button.addEventListener('click', () => {
  const number = await restartTask.perform();
  console.log(number); // 42
});

Getting the TaskInstance

If you don’t await the perform function, then you’ll get back the task instance that you can use either to cancel it or to get its current state. The TaskInstance is also an object with getters you can access the current value with instance.value or register events on it with instance.on.

Dot notation

import { task } from '@sheepdog/vanilla';

const restartTask = task.restart(async () => {
  // your code
});

button.addEventListener('click', () => {
  const lastRun = restartTask.perform();
  lastRun.on('success', () => {
    console.log(lastRun.value);
  });
  lastRun.cancel();
});

Options notation

import { task } from '@sheepdog/vanilla';

const restartTask = task(
  async () => {
    // your code
  },
  { kind: 'restart' },
);

button.addEventListener('click', () => {
  lastRun = restartTask.perform();
  lastRun.on('success', () => {
    console.log(lastRun.value);
  });
  lastRun.cancel();
});