taskbuffer/test/test.2.taskchain.ts

import { expect, tap } from '@push.rocks/tapbundle';

import * as taskbuffer from '../ts/index.js';

import * as smartpromise from '@push.rocks/smartpromise';
import * as smartdelay from '@push.rocks/smartdelay';

let task1Executed = false;
const task1 = new taskbuffer.Task({
  taskFunction: async () => {
    await smartdelay.delayFor(2000);
    task1Executed = true;
  },
});

let task2Executed = false;
const task2 = new taskbuffer.Task({
  taskFunction: async () => {
    await smartdelay.delayFor(2000);
    task2Executed = true;
  },
});

let task3Executed = false;
const task3 = new taskbuffer.Task({
  taskFunction: async () => {
    await smartdelay.delayFor(2000);
    task3Executed = true;
  },
});

tap.test('expect run tasks in sequence', async () => {
  const testTaskchain = new taskbuffer.Taskchain({
    name: 'Taskchain1',
    taskArray: [task1, task2, task3],
  });
  const testPromise = testTaskchain.trigger();
  await smartdelay.delayFor(2100);
  // tslint:disable-next-line:no-unused-expression
  expect(task1Executed).toBeTrue();
  // tslint:disable-next-line:no-unused-expression
  expect(task2Executed).toBeFalse();
  await smartdelay.delayFor(2100);
  // tslint:disable-next-line:no-unused-expression
  expect(task2Executed).toBeTrue();
  await testPromise;
});

tap.start();