feat(tasks): add repeat task

src/tasks/schedule/index.ts

@@ -1,2 +1,3 @@
+export * from './repeat';
 export * from './sleep';
 export * from './timeout';

src/tasks/schedule/repeat.ts

@@ -0,0 +1,26 @@
+import { Task } from '../../definitions';
+import { run } from '../../utils/run';
+import { isCancelled } from '../../utils/is-cancelled';
+import { series } from '../aggregate/series';
+import { log } from '../stdio/log';
+
+/**
+ * Run `task` for `times` repetitions,
+ * or indifinitely otherwise.
+ * @returns Task
+ */
+export function repeat(times: number | null, task: Task): Task.Async {
+  return series(
+    log('debug', 'Task repetition set at', times, 'times'),
+    async (ctx) => {
+      let i = 0;
+      const isDone = (): boolean => times !== null && times >= 0 && i >= times;
+
+      while (!isDone()) {
+        i++;
+        if (await isCancelled(ctx)) break;
+        await run(series(log('debug', 'Repeat task:', i), task), ctx);
+      }
+    }
+  );
+}

src/tasks/schedule/timeout.ts

@@ -19,7 +19,7 @@ export function timeout(
   return ms < 0
     ? series(log('debug', 'Timeout disabled:', ms), task)
     : series(
-        log('debug', 'Task timeout set at', ms),
+        log('debug', 'Task timeout set at', ms, 'milliseconds'),
         create(async (ctx) => {
           const altTask = alternate || raises('Task timeout');
           if (ms <= 0) return altTask;