2.1.15

fix(core): update
2.1.14
2021-11-11 19:59:56 +01:00 · 2021-11-11 19:59:56 +01:00 · 2021-09-26 14:45:02 +02:00 · 2021-09-26 14:45:02 +02:00 · 2020-09-07 23:52:23 +00:00 · 2020-09-07 23:52:22 +00:00
51 changed files with 28585 additions and 970 deletions
--- a/.gitignore
+++ b/.gitignore
@ -1,7 +1,20 @@
-.idea/
+.nogit/
+
+# artifacts
 coverage/
-docs/
-ts/*.js
-ts/*.js.map
-ts/typings/
-node_modules
+public/
+pages/
+
+# installs
+node_modules/
+
+# caches
+.yarn/
+.cache/
+.rpt2_cache
+
+# builds
+dist/
+dist_*/
+
+# custom
--- a/.gitlab-ci.yml
+++ b/.gitlab-ci.yml
@ -1,36 +1,137 @@
-image: hosttoday/ht-docker-node:npmts
+# gitzone ci_default
+image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
+
+cache:
+  paths:
+    - .npmci_cache/
+  key: '$CI_BUILD_STAGE'

 stages:
- test
- release
+  - security
+  - test
+  - release
+  - metadata

-testLEGACY:
-  stage: test
+# ====================
+# security stage
+# ====================
+mirror:
+  stage: security
  script:
-    - npmci test legacy
+    - npmci git mirror
+  only:
+    - tags
+  tags:
+    - lossless
+    - docker
+    - notpriv
+
+auditProductionDependencies:
+  image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
+  stage: security
+  script:
+    - npmci npm prepare
+    - npmci command npm install --production --ignore-scripts
+    - npmci command npm config set registry https://registry.npmjs.org
+    - npmci command npm audit --audit-level=high --only=prod --production
  tags:
    - docker

-testLTS:
-  stage: test
+auditDevDependencies:
+  image: registry.gitlab.com/hosttoday/ht-docker-node:npmci
+  stage: security
  script:
-    - npmci test lts
+    - npmci npm prepare
+    - npmci command npm install --ignore-scripts
+    - npmci command npm config set registry https://registry.npmjs.org
+    - npmci command npm audit --audit-level=high --only=dev
  tags:
    - docker
-    
-testSTABLE:
+  allow_failure: true
+
+# ====================
+# test stage
+# ====================
+
+testStable:
  stage: test
  script:
-    - npmci test stable
+    - npmci npm prepare
+    - npmci node install stable
+    - npmci npm install
+    - npmci npm test
+  coverage: /\d+.?\d+?\%\s*coverage/
+  tags:
+    - docker
+
+testBuild:
+  stage: test
+  script:
+    - npmci npm prepare
+    - npmci node install stable
+    - npmci npm install
+    - npmci command npm run build
+  coverage: /\d+.?\d+?\%\s*coverage/
  tags:
    - docker

 release:
  stage: release
-  environment: npmjs-com_registry
  script:
-    - npmci publish
+    - npmci node install stable
+    - npmci npm publish
  only:
    - tags
  tags:
-    - docker
+    - lossless
+    - docker
+    - notpriv
+
+# ====================
+# metadata stage
+# ====================
+codequality:
+  stage: metadata
+  allow_failure: true
+  only:
+    - tags
+  script:
+    - npmci command npm install -g tslint typescript
+    - npmci npm prepare
+    - npmci npm install
+    - npmci command "tslint -c tslint.json ./ts/**/*.ts"
+  tags:
+    - lossless
+    - docker
+    - priv
+
+trigger:
+  stage: metadata
+  script:
+    - npmci trigger
+  only:
+    - tags
+  tags:
+    - lossless
+    - docker
+    - notpriv
+
+pages:
+  stage: metadata
+  script:
+    - npmci node install lts
+    - npmci command npm install -g @gitzone/tsdoc
+    - npmci npm prepare
+    - npmci npm install
+    - npmci command tsdoc
+  tags:
+    - lossless
+    - docker
+    - notpriv
+  only:
+    - tags
+  artifacts:
+    expire_in: 1 week
+    paths:
+      - public
+  allow_failure: true
--- a/.npmignore
+++ b/.npmignore
@ -1,5 +1,5 @@
-.idea/
 docs/
 coverage/
 ts/
 node_modules/
+pages/
--- a/.vscode/launch.json
+++ b/.vscode/launch.json
@ -0,0 +1,29 @@
+{
+  "version": "0.2.0",
+  "configurations": [
+    {
+      "name": "current file",
+      "type": "node",
+      "request": "launch",
+      "args": [
+        "${relativeFile}"
+      ],
+      "runtimeArgs": ["-r", "@gitzone/tsrun"],
+      "cwd": "${workspaceRoot}",
+      "protocol": "inspector",
+      "internalConsoleOptions": "openOnSessionStart"
+    },
+    {
+      "name": "test.ts",
+      "type": "node",
+      "request": "launch",
+      "args": [
+        "test/test.ts"
+      ],
+      "runtimeArgs": ["-r", "@gitzone/tsrun"],
+      "cwd": "${workspaceRoot}",
+      "protocol": "inspector",
+      "internalConsoleOptions": "openOnSessionStart"
+    }
+  ]
+}
--- a/.vscode/settings.json
+++ b/.vscode/settings.json
@ -0,0 +1,26 @@
+{
+  "json.schemas": [
+    {
+      "fileMatch": ["/npmextra.json"],
+      "schema": {
+        "type": "object",
+        "properties": {
+          "npmci": {
+            "type": "object",
+            "description": "settings for npmci"
+          },
+          "gitzone": {
+            "type": "object",
+            "description": "settings for gitzone",
+            "properties": {
+              "projectType": {
+                "type": "string",
+                "enum": ["website", "element", "service", "npm", "wcc"]
+              }
+            }
+          }
+        }
+      }
+    }
+  ]
+}
--- a/README.md
+++ b/README.md
@ -1,56 +0,0 @@
-# taskbuffer
-Flexible task organization for gulp. TypeScript ready!
-
-## Status
-[![Coverage Status](https://coveralls.io/repos/github/pushrocks/taskbuffer/badge.svg?branch=master)](https://coveralls.io/github/pushrocks/taskbuffer?branch=master)
-
-## Install
-
-```sh
-npm install taskbuffer --save
-```
-
-## Concepts 
-
-### class `Task`
-* A Task in its most simple form is a function that is executed when the task runs.
-* A Task can have a **preTask** and an **afterTask**
-  (those are run before or after the main function whenever the task is called)
-* A Task can be buffered.
-  That means it can be called multiple times in a very short time.
-  However execution happens in line:
-  meaning execution of the task's main function is on halt until the previous task call has finished.
-  You can set bufferMax number, which is the max number of buffered task calls.
-  Any additional calls will then be truncated
-* Task.trigger() and Task.triggerBuffered() always return a Promise
-  which is fullfilled once the related task call has completed.
-* Task.triggered() is an Observable stream that emits events every time a task call is called and every time a call is completed.
-* Task is compatible to gulp streams.
-
-### class `TaskChain`
-* TaskChain extends Task.
-* Multiple Tasks can be combined in a bigger task using a TaskChain.
-* While the tasks are async in themselve, TaskChain **runs Tasks serialized** (one after the other)
-* that means that tasks can rely on each other and 
-
-### class `TaskParallel`
-* TaskParallel extends Task.
-* like TaskChain, however **tasks run in parallel**
-* Tasks cannot rely on each other.
-
-### Usage
-We highly recommend TypeScript as this module supports **TypeScript intellisense**.
-```
-import * as taskbuffer from "taskbuffer";
-
-myTask = new taskbuffer.Task({
-  preTask: someOtherTask // optional, don't worry loops are prevented
-  afterTask: someOtherTask // optional, don't worry loops are prevented
-  name:"myTask1",
-  taskFunction:() => {
-    // do some stuff and return promise
-    // pass on any data through promise resolution
-    // Use TypeScript for better understanding and code completion
-  }
-})
-```
--- a/dist/index.d.ts
+++ b/dist/index.d.ts
@ -1,5 +0,0 @@
-export { Task, ITaskFunction } from "./taskbuffer.classes.task";
-export { Taskchain } from "./taskbuffer.classes.taskchain";
-export { Taskparallel } from "./taskbuffer.classes.taskparallel";
-export { Taskspace } from "./taskbuffer.classes.taskspace";
-import "./taskbuffer.classes.helpers";
--- a/dist/index.js
+++ b/dist/index.js
@ -1,12 +0,0 @@
-"use strict";
-var taskbuffer_classes_task_1 = require("./taskbuffer.classes.task");
-exports.Task = taskbuffer_classes_task_1.Task;
-var taskbuffer_classes_taskchain_1 = require("./taskbuffer.classes.taskchain");
-exports.Taskchain = taskbuffer_classes_taskchain_1.Taskchain;
-var taskbuffer_classes_taskparallel_1 = require("./taskbuffer.classes.taskparallel");
-exports.Taskparallel = taskbuffer_classes_taskparallel_1.Taskparallel;
-var taskbuffer_classes_taskspace_1 = require("./taskbuffer.classes.taskspace");
-exports.Taskspace = taskbuffer_classes_taskspace_1.Taskspace;
-// import for naming only
-require("./taskbuffer.classes.helpers");
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsd0NBQWlDLDJCQUEyQixDQUFDO0FBQXJELDhDQUFxRDtBQUM3RCw2Q0FBd0IsZ0NBQWdDLENBQUM7QUFBakQsNkRBQWlEO0FBQ3pELGdEQUEyQixtQ0FBbUMsQ0FBQztBQUF2RCxzRUFBdUQ7QUFDL0QsNkNBQXdCLGdDQUFnQyxDQUFDO0FBQWpELDZEQUFpRDtBQUV6RCx5QkFBeUI7QUFDekIsUUFBTyw4QkFBOEIsQ0FBQyxDQUFEIn0=
--- a/dist/taskbuffer.classes.helpers.d.ts
+++ b/dist/taskbuffer.classes.helpers.d.ts
@ -1,10 +0,0 @@
-/// <reference types="q" />
-import plugins = require("./taskbuffer.plugins");
-import { Task, ITaskFunction } from "./taskbuffer.classes.task";
-export declare let emptyTaskFunction: ITaskFunction;
-export declare let isTask: (taskArg: any) => boolean;
-export declare let isTaskTouched: (taskArg: Task, touchedTasksArray: Task[]) => boolean;
-export declare let runTask: (taskArg: Task, optionsArg?: {
-    touchedTasksArray: Task[];
-}) => plugins.Q.Promise<{}>;
-export declare let runBufferedTask: (taskArg: Task) => void;
--- a/dist/taskbuffer.classes.helpers.js
+++ b/dist/taskbuffer.classes.helpers.js
@ -1,83 +0,0 @@
-"use strict";
-const plugins = require("./taskbuffer.plugins");
-const taskbuffer_classes_task_1 = require("./taskbuffer.classes.task");
-exports.emptyTaskFunction = function () {
-    let done = plugins.Q.defer();
-    done.resolve();
-    return done.promise;
-};
-exports.isTask = function (taskArg) {
-    if (taskArg instanceof taskbuffer_classes_task_1.Task
-        && typeof taskArg.task === "function") {
-        return true;
-    }
-    else {
-        return false;
-    }
-};
-exports.isTaskTouched = (taskArg, touchedTasksArray) => {
-    let result = false;
-    for (let keyArg in touchedTasksArray) {
-        if (taskArg === touchedTasksArray[keyArg]) {
-            result = true;
-        }
-    }
-    return result;
-};
-exports.runTask = function (taskArg, optionsArg = { touchedTasksArray: [] }) {
-    let done = plugins.Q.defer();
-    taskArg.running = true;
-    done.promise.then(function () { taskArg.running = false; });
-    let localDeferred = plugins.Q.defer();
-    let touchedTasksArray;
-    if (optionsArg.touchedTasksArray) {
-        touchedTasksArray = optionsArg.touchedTasksArray;
-    }
-    else {
-        touchedTasksArray = [];
-    }
-    touchedTasksArray.push(taskArg);
-    localDeferred.promise
-        .then(() => {
-        if (taskArg.preTask && !exports.isTaskTouched(taskArg.preTask, touchedTasksArray)) {
-            return exports.runTask(taskArg.preTask, { touchedTasksArray: touchedTasksArray });
-        }
-        else {
-            let done2 = plugins.Q.defer();
-            done2.resolve();
-            return done2.promise;
-        }
-    })
-        .then(() => {
-        return taskArg.task();
-    })
-        .then(() => {
-        if (taskArg.afterTask && !exports.isTaskTouched(taskArg.afterTask, touchedTasksArray)) {
-            return exports.runTask(taskArg.afterTask, { touchedTasksArray: touchedTasksArray });
-        }
-        else {
-            let done2 = plugins.Q.defer();
-            done2.resolve();
-            return done2.promise;
-        }
-    })
-        .then(() => {
-        done.resolve();
-    });
-    localDeferred.resolve();
-    return done.promise;
-};
-exports.runBufferedTask = (taskArg) => {
-    let recursiveBufferRunner = () => {
-        if (taskArg.bufferCounter > 0) {
-            taskArg.runningBuffered = true;
-            taskArg.bufferCounter--;
-            exports.runTask(taskArg)
-                .then(recursiveBufferRunner);
-        }
-        else {
-            taskArg.runningBuffered = false;
-        }
-    };
-};
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5jbGFzc2VzLmhlbHBlcnMuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy90YXNrYnVmZmVyLmNsYXNzZXMuaGVscGVycy50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsTUFBTyxPQUFPLFdBQVcsc0JBQXNCLENBQUMsQ0FBQztBQUNqRCwwQ0FBaUMsMkJBQTJCLENBQUMsQ0FBQTtBQUVsRCx5QkFBaUIsR0FBaUI7SUFDekMsSUFBSSxJQUFJLEdBQUcsT0FBTyxDQUFDLENBQUMsQ0FBQyxLQUFLLEVBQUUsQ0FBQztJQUM3QixJQUFJLENBQUMsT0FBTyxFQUFFLENBQUM7SUFDZixNQUFNLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQztBQUN4QixDQUFDLENBQUM7QUFFUyxjQUFNLEdBQUcsVUFBUyxPQUFPO0lBQ2hDLEVBQUUsQ0FBQSxDQUNFLE9BQU8sWUFBWSw4QkFBSTtXQUNwQixPQUFPLE9BQU8sQ0FBQyxJQUFJLEtBQUssVUFDL0IsQ0FBQyxDQUFBLENBQUM7UUFDRSxNQUFNLENBQUMsSUFBSSxDQUFDO0lBQ2hCLENBQUM7SUFBQyxJQUFJLENBQUMsQ0FBQztRQUNKLE1BQU0sQ0FBQyxLQUFLLENBQUM7SUFDakIsQ0FBQztBQUNMLENBQUMsQ0FBQztBQUdTLHFCQUFhLEdBQUcsQ0FBQyxPQUFZLEVBQUUsaUJBQXdCO0lBQzlELElBQUksTUFBTSxHQUFHLEtBQUssQ0FBQztJQUNuQixHQUFHLENBQUMsQ0FBQyxJQUFJLE1BQU0sSUFBSSxpQkFBaUIsQ0FBQyxDQUFBLENBQUM7UUFDbEMsRUFBRSxDQUFBLENBQUMsT0FBTyxLQUFLLGlCQUFpQixDQUFDLE1BQU0sQ0FBQyxDQUFDLENBQUEsQ0FBQztZQUN0QyxNQUFNLEdBQUcsSUFBSSxDQUFDO1FBQ2xCLENBQUM7SUFDTCxDQUFDO0lBQ0QsTUFBTSxDQUFDLE1BQU0sQ0FBQztBQUNsQixDQUFDLENBQUE7QUFFVSxlQUFPLEdBQUcsVUFBUyxPQUFZLEVBQUMsVUFBVSxHQUE4QixFQUFDLGlCQUFpQixFQUFDLEVBQUUsRUFBQztJQUNyRyxJQUFJLElBQUksR0FBRyxPQUFPLENBQUMsQ0FBQyxDQUFDLEtBQUssRUFBRSxDQUFDO0lBQzdCLE9BQU8sQ0FBQyxPQUFPLEdBQUcsSUFBSSxDQUFDO0lBQ3ZCLElBQUksQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLGNBQVcsT0FBTyxDQUFDLE9BQU8sR0FBRyxLQUFLLENBQUEsQ0FBQSxDQUFDLENBQUMsQ0FBQztJQUN2RCxJQUFJLGFBQWEsR0FBRyxPQUFPLENBQUMsQ0FBQyxDQUFDLEtBQUssRUFBRSxDQUFDO0lBQ3RDLElBQUksaUJBQXdCLENBQUM7SUFDN0IsRUFBRSxDQUFBLENBQUMsVUFBVSxDQUFDLGlCQUFpQixDQUFDLENBQUEsQ0FBQztRQUM3QixpQkFBaUIsR0FBRyxVQUFVLENBQUMsaUJBQWlCLENBQUM7SUFDckQsQ0FBQztJQUFDLElBQUksQ0FBQyxDQUFDO1FBQ0osaUJBQWlCLEdBQUcsRUFBRSxDQUFDO0lBQzNCLENBQUM7SUFDRCxpQkFBaUIsQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFDLENBQUM7SUFDaEMsYUFBYSxDQUFDLE9BQU87U0FDaEIsSUFBSSxDQUFDO1FBQ0YsRUFBRSxDQUFBLENBQUMsT0FBTyxDQUFDLE9BQU8sSUFBSSxDQUFDLHFCQUFhLENBQUMsT0FBTyxDQUFDLE9BQU8sRUFBQyxpQkFBaUIsQ0FBQyxDQUFDLENBQUEsQ0FBQztZQUNyRSxNQUFNLENBQUMsZUFBTyxDQUFDLE9BQU8sQ0FBQyxPQUFPLEVBQUMsRUFBQyxpQkFBaUIsRUFBQyxpQkFBaUIsRUFBQyxDQUFDLENBQUE7UUFDekUsQ0FBQztRQUFDLElBQUksQ0FBQyxDQUFDO1lBQ0osSUFBSSxLQUFLLEdBQUcsT0FBTyxDQUFDLENBQUMsQ0FBQyxLQUFLLEVBQUUsQ0FBQztZQUM5QixLQUFLLENBQUMsT0FBTyxFQUFFLENBQUM7WUFDaEIsTUFBTSxDQUFDLEtBQUssQ0FBQyxPQUFPLENBQUM7UUFDekIsQ0FBQztJQUNMLENBQUMsQ0FBQztTQUNELElBQUksQ0FBQztRQUNGLE1BQU0sQ0FBQyxPQUFPLENBQUMsSUFBSSxFQUFFLENBQUM7SUFDMUIsQ0FBQyxDQUFDO1NBQ0QsSUFBSSxDQUFDO1FBQ0YsRUFBRSxDQUFBLENBQUMsT0FBTyxDQUFDLFNBQVMsSUFBSSxDQUFDLHFCQUFhLENBQUMsT0FBTyxDQUFDLFNBQVMsRUFBQyxpQkFBaUIsQ0FBQyxDQUFDLENBQUEsQ0FBQztZQUN6RSxNQUFNLENBQUMsZUFBTyxDQUFDLE9BQU8sQ0FBQyxTQUFTLEVBQUMsRUFBQyxpQkFBaUIsRUFBQyxpQkFBaUIsRUFBQyxDQUFDLENBQUE7UUFDM0UsQ0FBQztRQUFDLElBQUksQ0FBQyxDQUFDO1lBQ0osSUFBSSxLQUFLLEdBQUcsT0FBTyxDQUFDLENBQUMsQ0FBQyxLQUFLLEVBQUUsQ0FBQztZQUM5QixLQUFLLENBQUMsT0FBTyxFQUFFLENBQUM7WUFDaEIsTUFBTSxDQUFDLEtBQUssQ0FBQyxPQUFPLENBQUM7UUFDekIsQ0FBQztJQUNMLENBQUMsQ0FBQztTQUNELElBQUksQ0FBQztRQUNGLElBQUksQ0FBQyxPQUFPLEVBQUUsQ0FBQztJQUNuQixDQUFDLENBQUMsQ0FBQztJQUNQLGFBQWEsQ0FBQyxPQUFPLEVBQUUsQ0FBQztJQUN4QixNQUFNLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQztBQUN4QixDQUFDLENBQUM7QUFFUyx1QkFBZSxHQUFHLENBQUMsT0FBWTtJQUN0QyxJQUFJLHFCQUFxQixHQUFHO1FBQ3hCLEVBQUUsQ0FBQSxDQUFDLE9BQU8sQ0FBQyxhQUFhLEdBQUcsQ0FBQyxDQUFDLENBQUEsQ0FBQztZQUMxQixPQUFPLENBQUMsZUFBZSxHQUFHLElBQUksQ0FBQztZQUMvQixPQUFPLENBQUMsYUFBYSxFQUFFLENBQUM7WUFDeEIsZUFBTyxDQUFDLE9BQU8sQ0FBQztpQkFDWCxJQUFJLENBQUMscUJBQXFCLENBQUMsQ0FBQztRQUNyQyxDQUFDO1FBQUMsSUFBSSxDQUFDLENBQUM7WUFDSixPQUFPLENBQUMsZUFBZSxHQUFHLEtBQUssQ0FBQztRQUNwQyxDQUFDO0lBQ0wsQ0FBQyxDQUFBO0FBQ0wsQ0FBQyxDQUFDIn0=
--- a/dist/taskbuffer.classes.task.d.ts
+++ b/dist/taskbuffer.classes.task.d.ts
@ -1,40 +0,0 @@
-/// <reference types="q" />
-import * as plugins from "./taskbuffer.plugins";
-export interface ITaskFunction {
-    (): PromiseLike<any>;
-}
-export declare class Task {
-    name: string;
-    task: any;
-    running: boolean;
-    runningBuffered: boolean;
-    idle: boolean;
-    buffered: boolean;
-    bufferCounter: number;
-    bufferMax: number;
-    private _counterTriggerAbsolute;
-    private _state;
-    preTask: Task;
-    afterTask: Task;
-    constructor(optionsArg: {
-        taskFunction: ITaskFunction;
-        preTask?: Task;
-        afterTask?: Task;
-        buffered?: boolean;
-        bufferMax?: number;
-        name?: string;
-    });
-    /**
-     * trigger the task. Will trigger buffered if this.buffered is true
-     */
-    trigger(): plugins.Q.Promise<{}>;
-    /**
-     * trigger task unbuffered.
-     */
-    triggerUnBuffered(): plugins.Q.Promise<{}>;
-    /**
-     * trigger task buffered.
-     */
-    triggerBuffered(): plugins.Q.Promise<{}>;
-    state: string;
-}
--- a/dist/taskbuffer.classes.task.js
+++ b/dist/taskbuffer.classes.task.js
@ -1,73 +0,0 @@
-"use strict";
-const plugins = require("./taskbuffer.plugins");
-const helpers = require("./taskbuffer.classes.helpers");
-class Task {
-    constructor(optionsArg) {
-        this.running = false;
-        this.runningBuffered = false;
-        this.idle = true;
-        this.buffered = false;
-        this.bufferMax = 1;
-        this._counterTriggerAbsolute = 0;
-        var options = optionsArg;
-        this.task = optionsArg.taskFunction;
-        this.preTask = options.preTask;
-        this.afterTask = options.afterTask;
-        this.running = false;
-        this.idle = !this.running && !this.runningBuffered;
-        this.buffered = options.buffered;
-        this.bufferMax = options.bufferMax;
-        this.name = options.name;
-    }
-    /**
-     * trigger the task. Will trigger buffered if this.buffered is true
-     */
-    trigger() {
-        let done = plugins.Q.defer();
-        if (this.buffered) {
-            this.triggerBuffered()
-                .then(done.resolve);
-        }
-        else {
-            this.triggerUnBuffered()
-                .then(done.resolve);
-        }
-        ;
-        return done.promise;
-    }
-    ;
-    /**
-     * trigger task unbuffered.
-     */
-    triggerUnBuffered() {
-        return helpers.runTask(this);
-    }
-    /**
-     * trigger task buffered.
-     */
-    triggerBuffered() {
-        var done = plugins.Q.defer();
-        if (!(this.bufferCounter >= this.bufferMax)) {
-            this.bufferCounter++;
-        }
-        ;
-        if (!this.runningBuffered) {
-            helpers.runBufferedTask(this);
-        }
-        ;
-        return done.promise;
-    }
-    get state() {
-        return this._state;
-    }
-    set state(stateArg) {
-        if (stateArg == "locked") {
-            this._state = "locked";
-        }
-        else {
-            plugins.beautylog.error("state type " + stateArg.blue + " could not be set");
-        }
-    }
-}
-exports.Task = Task;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5jbGFzc2VzLnRhc2suanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy90YXNrYnVmZmVyLmNsYXNzZXMudGFzay50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsTUFBWSxPQUFPLFdBQU0sc0JBQ3pCLENBQUMsQ0FEOEM7QUFDL0MsTUFBWSxPQUFPLFdBQU0sOEJBR3pCLENBQUMsQ0FIc0Q7QUFPdkQ7SUFjSSxZQUFZLFVBT1g7UUFsQkQsWUFBTyxHQUFXLEtBQUssQ0FBQztRQUN4QixvQkFBZSxHQUFXLEtBQUssQ0FBQztRQUNoQyxTQUFJLEdBQVcsSUFBSSxDQUFDO1FBQ3BCLGFBQVEsR0FBVyxLQUFLLENBQUM7UUFFekIsY0FBUyxHQUFVLENBQUMsQ0FBQztRQUNiLDRCQUF1QixHQUFVLENBQUMsQ0FBQztRQWF2QyxJQUFJLE9BQU8sR0FBRyxVQUFVLENBQUM7UUFDekIsSUFBSSxDQUFDLElBQUksR0FBRyxVQUFVLENBQUMsWUFBWSxDQUFDO1FBQ3BDLElBQUksQ0FBQyxPQUFPLEdBQUcsT0FBTyxDQUFDLE9BQU8sQ0FBQztRQUMvQixJQUFJLENBQUMsU0FBUyxHQUFHLE9BQU8sQ0FBQyxTQUFTLENBQUM7UUFDbkMsSUFBSSxDQUFDLE9BQU8sR0FBRyxLQUFLLENBQUM7UUFDckIsSUFBSSxDQUFDLElBQUksR0FBRyxDQUFDLElBQUksQ0FBQyxPQUFPLElBQUksQ0FBQyxJQUFJLENBQUMsZUFBZSxDQUFDO1FBQ25ELElBQUksQ0FBQyxRQUFRLEdBQUcsT0FBTyxDQUFDLFFBQVEsQ0FBQztRQUNqQyxJQUFJLENBQUMsU0FBUyxHQUFHLE9BQU8sQ0FBQyxTQUFTLENBQUM7UUFDbkMsSUFBSSxDQUFDLElBQUksR0FBRyxPQUFPLENBQUMsSUFBSSxDQUFDO0lBQzdCLENBQUM7SUFFRDs7T0FFRztJQUNILE9BQU87UUFDSCxJQUFJLElBQUksR0FBRyxPQUFPLENBQUMsQ0FBQyxDQUFDLEtBQUssRUFBRSxDQUFDO1FBQzdCLEVBQUUsQ0FBQSxDQUFDLElBQUksQ0FBQyxRQUFRLENBQUMsQ0FBQyxDQUFDO1lBQ2YsSUFBSSxDQUFDLGVBQWUsRUFBRTtpQkFDakIsSUFBSSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUMsQ0FBQztRQUM1QixDQUFDO1FBQ0QsSUFBSSxDQUFDLENBQUM7WUFDRixJQUFJLENBQUMsaUJBQWlCLEVBQUU7aUJBQ25CLElBQUksQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFDLENBQUM7UUFDNUIsQ0FBQztRQUFBLENBQUM7UUFDRixNQUFNLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQztJQUN4QixDQUFDOztJQUVEOztPQUVHO0lBQ0gsaUJBQWlCO1FBQ2IsTUFBTSxDQUFDLE9BQU8sQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLENBQUM7SUFDakMsQ0FBQztJQUVEOztPQUVHO0lBQ0gsZUFBZTtRQUNYLElBQUksSUFBSSxHQUFHLE9BQU8sQ0FBQyxDQUFDLENBQUMsS0FBSyxFQUFFLENBQUM7UUFDN0IsRUFBRSxDQUFBLENBQUMsQ0FBQyxDQUFDLElBQUksQ0FBQyxhQUFhLElBQUksSUFBSSxDQUFDLFNBQVMsQ0FBQyxDQUFDLENBQUEsQ0FBQztZQUN4QyxJQUFJLENBQUMsYUFBYSxFQUFFLENBQUE7UUFDeEIsQ0FBQztRQUFBLENBQUM7UUFDRixFQUFFLENBQUEsQ0FBQyxDQUFDLElBQUksQ0FBQyxlQUFlLENBQUMsQ0FBQSxDQUFDO1lBQ3RCLE9BQU8sQ0FBQyxlQUFlLENBQUMsSUFBSSxDQUFDLENBQUM7UUFDbEMsQ0FBQztRQUFBLENBQUM7UUFDRixNQUFNLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQztJQUN4QixDQUFDO0lBRUQsSUFBSSxLQUFLO1FBQ0wsTUFBTSxDQUFDLElBQUksQ0FBQyxNQUFNLENBQUM7SUFDdkIsQ0FBQztJQUNELElBQUksS0FBSyxDQUFDLFFBQWU7UUFDckIsRUFBRSxDQUFDLENBQUMsUUFBUSxJQUFJLFFBQVEsQ0FBQyxDQUFBLENBQUM7WUFDdEIsSUFBSSxDQUFDLE1BQU0sR0FBRyxRQUFRLENBQUM7UUFDM0IsQ0FBQztRQUFDLElBQUksQ0FBQyxDQUFDO1lBQ0osT0FBTyxDQUFDLFNBQVMsQ0FBQyxLQUFLLENBQUMsYUFBYSxHQUFHLFFBQVEsQ0FBQyxJQUFJLEdBQUcsbUJBQW1CLENBQUMsQ0FBQztRQUNqRixDQUFDO0lBQ0wsQ0FBQztBQUNMLENBQUM7QUFoRlksWUFBSSxPQWdGaEIsQ0FBQSJ9
--- a/dist/taskbuffer.classes.taskchain.d.ts
+++ b/dist/taskbuffer.classes.taskchain.d.ts
@ -1,14 +0,0 @@
-import { Task } from "./taskbuffer.classes.task";
-export declare class Taskchain extends Task {
-    taskArray: Task[];
-    private _oraObject;
-    constructor(optionsArg: {
-        name?: string;
-        log?: boolean;
-        taskArray: Task[];
-    });
-    addTask(taskArg: Task): void;
-    removeTask(taskArg: Task): void;
-    shiftTask(): void;
-    trigger(): any;
-}
--- a/dist/taskbuffer.classes.taskchain.js
+++ b/dist/taskbuffer.classes.taskchain.js
@ -1,59 +0,0 @@
-"use strict";
-const plugins = require("./taskbuffer.plugins");
-const taskbuffer_classes_task_1 = require("./taskbuffer.classes.task");
-const helpers = require("./taskbuffer.classes.helpers");
-class Taskchain extends taskbuffer_classes_task_1.Task {
-    constructor(optionsArg) {
-        let options = plugins.lodash.merge({
-            name: "unnamed Taskchain",
-            log: false
-        }, optionsArg, {
-            taskFunction: () => {
-                let done = plugins.Q.defer(); // this is the starting Deferred object 
-                let taskCounter = 0;
-                let iterateTasks = () => {
-                    if (typeof this.taskArray[taskCounter] != "undefined") {
-                        this._oraObject.text(this.name + " running: Task" + this.taskArray[taskCounter].name);
-                        this.taskArray[taskCounter].trigger()
-                            .then(() => {
-                            plugins.beautylog.ok(this.taskArray[taskCounter].name);
-                            taskCounter++;
-                            iterateTasks();
-                        });
-                    }
-                    else {
-                        this._oraObject.endOk("Taskchain \"" + this.name + "\" completed successfully");
-                        done.resolve();
-                    }
-                };
-                iterateTasks();
-                return done.promise;
-            }
-        });
-        super(options);
-        this.taskArray = optionsArg.taskArray;
-        this._oraObject = new plugins.beautylog.Ora("Taskchain idle", "blue");
-        if (optionsArg.log === true) {
-            this._oraObject.start();
-        }
-        ;
-    }
-    addTask(taskArg) {
-        this.taskArray.push(taskArg);
-    }
-    ;
-    removeTask(taskArg) {
-        //TODO
-    }
-    ;
-    shiftTask() {
-    }
-    ;
-    trigger() {
-        this._oraObject.start(this.name + " running...");
-        return helpers.runTask(this);
-    }
-}
-exports.Taskchain = Taskchain;
-;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5jbGFzc2VzLnRhc2tjaGFpbi5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL3Rhc2tidWZmZXIuY2xhc3Nlcy50YXNrY2hhaW4udHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLE1BQVksT0FBTyxXQUFNLHNCQUFzQixDQUFDLENBQUE7QUFDaEQsMENBQW1CLDJCQUEyQixDQUFDLENBQUE7QUFDL0MsTUFBTyxPQUFPLFdBQVcsOEJBQThCLENBQUMsQ0FBQztBQUV6RCx3QkFBK0IsOEJBQUk7SUFHL0IsWUFBWSxVQUlYO1FBQ0csSUFBSSxPQUFPLEdBQUcsT0FBTyxDQUFDLE1BQU0sQ0FBQyxLQUFLLENBQzlCO1lBQ0ksSUFBSSxFQUFDLG1CQUFtQjtZQUN4QixHQUFHLEVBQUMsS0FBSztTQUNaLEVBQ0QsVUFBVSxFQUNWO1lBQ0ksWUFBWSxFQUFFO2dCQUNWLElBQUksSUFBSSxHQUFHLE9BQU8sQ0FBQyxDQUFDLENBQUMsS0FBSyxFQUFFLENBQUMsQ0FBQyx3Q0FBd0M7Z0JBQ3RFLElBQUksV0FBVyxHQUFHLENBQUMsQ0FBQztnQkFDcEIsSUFBSSxZQUFZLEdBQUc7b0JBQ2YsRUFBRSxDQUFBLENBQUMsT0FBTyxJQUFJLENBQUMsU0FBUyxDQUFDLFdBQVcsQ0FBQyxJQUFJLFdBQVcsQ0FBQyxDQUFBLENBQUM7d0JBQ2xELElBQUksQ0FBQyxVQUFVLENBQUMsSUFBSSxDQUFDLElBQUksQ0FBQyxJQUFJLEdBQUcsZ0JBQWdCLEdBQUcsSUFBSSxDQUFDLFNBQVMsQ0FBQyxXQUFXLENBQUMsQ0FBQyxJQUFJLENBQUMsQ0FBQzt3QkFDdEYsSUFBSSxDQUFDLFNBQVMsQ0FBQyxXQUFXLENBQUMsQ0FBQyxPQUFPLEVBQUU7NkJBQ2hDLElBQUksQ0FBQzs0QkFDRixPQUFPLENBQUMsU0FBUyxDQUFDLEVBQUUsQ0FBQyxJQUFJLENBQUMsU0FBUyxDQUFDLFdBQVcsQ0FBQyxDQUFDLElBQUksQ0FBQyxDQUFDOzRCQUN2RCxXQUFXLEVBQUUsQ0FBQzs0QkFDZCxZQUFZLEVBQUUsQ0FBQzt3QkFDbkIsQ0FBQyxDQUFDLENBQUM7b0JBQ1gsQ0FBQztvQkFBQyxJQUFJLENBQUMsQ0FBQzt3QkFDSixJQUFJLENBQUMsVUFBVSxDQUFDLEtBQUssQ0FBQyxjQUFjLEdBQUcsSUFBSSxDQUFDLElBQUksR0FBSSwyQkFBMkIsQ0FBQyxDQUFDO3dCQUNqRixJQUFJLENBQUMsT0FBTyxFQUFFLENBQUM7b0JBQ25CLENBQUM7Z0JBQ0wsQ0FBQyxDQUFDO2dCQUNGLFlBQVksRUFBRSxDQUFDO2dCQUNmLE1BQU0sQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFDO1lBQ3hCLENBQUM7U0FDSixDQUNKLENBQUM7UUFDRixNQUFNLE9BQU8sQ0FBQyxDQUFDO1FBQ2YsSUFBSSxDQUFDLFNBQVMsR0FBRyxVQUFVLENBQUMsU0FBUyxDQUFDO1FBQ3RDLElBQUksQ0FBQyxVQUFVLEdBQUcsSUFBSSxPQUFPLENBQUMsU0FBUyxDQUFDLEdBQUcsQ0FBQyxnQkFBZ0IsRUFBQyxNQUFNLENBQUMsQ0FBQztRQUNyRSxFQUFFLENBQUEsQ0FBQyxVQUFVLENBQUMsR0FBRyxLQUFLLElBQUksQ0FBQyxDQUFBLENBQUM7WUFDeEIsSUFBSSxDQUFDLFVBQVUsQ0FBQyxLQUFLLEVBQUUsQ0FBQztRQUM1QixDQUFDO1FBQUEsQ0FBQztJQUNOLENBQUM7SUFDRCxPQUFPLENBQUMsT0FBWTtRQUNoQixJQUFJLENBQUMsU0FBUyxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUMsQ0FBQztJQUNqQyxDQUFDOztJQUNELFVBQVUsQ0FBQyxPQUFZO1FBQ25CLE1BQU07SUFDVixDQUFDOztJQUNELFNBQVM7SUFFVCxDQUFDOztJQUNELE9BQU87UUFDSCxJQUFJLENBQUMsVUFBVSxDQUFDLEtBQUssQ0FBQyxJQUFJLENBQUMsSUFBSSxHQUFHLGFBQWEsQ0FBQyxDQUFDO1FBQ2pELE1BQU0sQ0FBQyxPQUFPLENBQUMsT0FBTyxDQUFDLElBQUksQ0FBQyxDQUFDO0lBQ2pDLENBQUM7QUFDTCxDQUFDO0FBekRZLGlCQUFTLFlBeURyQixDQUFBO0FBQUEsQ0FBQyJ9
--- a/dist/taskbuffer.classes.taskparallel.d.ts
+++ b/dist/taskbuffer.classes.taskparallel.d.ts
@ -1,7 +0,0 @@
-import { Task } from "./taskbuffer.classes.task";
-export declare class Taskparallel extends Task {
-    taskArray: Task[];
-    constructor(optionsArg: {
-        taskArray: Task[];
-    });
-}
--- a/dist/taskbuffer.classes.taskparallel.js
+++ b/dist/taskbuffer.classes.taskparallel.js
@ -1,23 +0,0 @@
-"use strict";
-const plugins = require("./taskbuffer.plugins");
-const taskbuffer_classes_task_1 = require("./taskbuffer.classes.task");
-class Taskparallel extends taskbuffer_classes_task_1.Task {
-    constructor(optionsArg) {
-        let options = plugins.lodash.merge(optionsArg, {
-            taskFunction: () => {
-                let done = plugins.Q.defer();
-                let promiseArray = []; // stores promises of all tasks, since they run in parallel
-                this.taskArray.forEach(function (taskArg) {
-                    promiseArray.push(taskArg.trigger());
-                });
-                plugins.Q.all(promiseArray)
-                    .then(done.resolve);
-                return done.promise;
-            }
-        });
-        super(options);
-        this.taskArray = optionsArg.taskArray;
-    }
-}
-exports.Taskparallel = Taskparallel;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5jbGFzc2VzLnRhc2twYXJhbGxlbC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL3Rhc2tidWZmZXIuY2xhc3Nlcy50YXNrcGFyYWxsZWwudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLE1BQVksT0FBTyxXQUFNLHNCQUN6QixDQUFDLENBRDhDO0FBRS9DLDBDQUFxQiwyQkFFckIsQ0FBQyxDQUYrQztBQUVoRCwyQkFBa0MsOEJBQUk7SUFFbEMsWUFBWSxVQUVYO1FBQ0csSUFBSSxPQUFPLEdBQUcsT0FBTyxDQUFDLE1BQU0sQ0FBQyxLQUFLLENBQzlCLFVBQVUsRUFDVjtZQUNJLFlBQVksRUFBRTtnQkFDVixJQUFJLElBQUksR0FBRyxPQUFPLENBQUMsQ0FBQyxDQUFDLEtBQUssRUFBRSxDQUFDO2dCQUM3QixJQUFJLFlBQVksR0FBc0IsRUFBRSxDQUFDLENBQUMsMkRBQTJEO2dCQUNyRyxJQUFJLENBQUMsU0FBUyxDQUFDLE9BQU8sQ0FBQyxVQUFVLE9BQU87b0JBQ3BDLFlBQVksQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFDLE9BQU8sRUFBRSxDQUFDLENBQUM7Z0JBQ3pDLENBQUMsQ0FBQyxDQUFBO2dCQUNGLE9BQU8sQ0FBQyxDQUFDLENBQUMsR0FBRyxDQUFDLFlBQVksQ0FBQztxQkFDdEIsSUFBSSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUMsQ0FBQztnQkFDeEIsTUFBTSxDQUFDLElBQUksQ0FBQyxPQUFPLENBQUM7WUFDeEIsQ0FBQztTQUNKLENBQ0osQ0FBQztRQUNGLE1BQU0sT0FBTyxDQUFDLENBQUM7UUFDZixJQUFJLENBQUMsU0FBUyxHQUFHLFVBQVUsQ0FBQyxTQUFTLENBQUM7SUFDMUMsQ0FBQztBQUNMLENBQUM7QUF2Qlksb0JBQVksZUF1QnhCLENBQUEifQ==
--- a/dist/taskbuffer.classes.taskspace.d.ts
+++ b/dist/taskbuffer.classes.taskspace.d.ts
@ -1,2 +0,0 @@
-export declare class Taskspace {
-}
--- a/dist/taskbuffer.classes.taskspace.js
+++ b/dist/taskbuffer.classes.taskspace.js
@ -1,5 +0,0 @@
-"use strict";
-class Taskspace {
-}
-exports.Taskspace = Taskspace;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5jbGFzc2VzLnRhc2tzcGFjZS5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL3Rhc2tidWZmZXIuY2xhc3Nlcy50YXNrc3BhY2UudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUdBO0FBRUEsQ0FBQztBQUZZLGlCQUFTLFlBRXJCLENBQUEifQ==
--- a/dist/taskbuffer.plugins.d.ts
+++ b/dist/taskbuffer.plugins.d.ts
@ -1,5 +0,0 @@
-import "typings-global";
-export import beautylog = require("beautylog");
-export import Q = require("q");
-export import lodash = require("lodash");
-export import rxjs = require("rxjs");
--- a/dist/taskbuffer.plugins.js
+++ b/dist/taskbuffer.plugins.js
@ -1,7 +0,0 @@
-"use strict";
-require("typings-global");
-exports.beautylog = require("beautylog");
-exports.Q = require("q");
-exports.lodash = require("lodash");
-exports.rxjs = require("rxjs");
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGFza2J1ZmZlci5wbHVnaW5zLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vdHMvdGFza2J1ZmZlci5wbHVnaW5zLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7QUFBQSxRQUFPLGdCQUNQLENBQUMsQ0FEc0I7QUFDVCxpQkFBUyxXQUFXLFdBQVcsQ0FBQyxDQUFDO0FBQ2pDLFNBQUMsV0FBVyxHQUFHLENBQUMsQ0FBQztBQUNqQixjQUFNLFdBQVUsUUFBUSxDQUFDLENBQUM7QUFDMUIsWUFBSSxXQUFXLE1BQU0sQ0FBQyxDQUFDIn0=
--- a/npmextra.json
+++ b/npmextra.json
@ -1,5 +1,18 @@
 {
-  "npmts":{
-    "mode":"default"
+  "npmci": {
+    "npmGlobalTools": [],
+    "npmAccessLevel": "public",
+    "npmRegistryUrl": "registry.npmjs.org"
+  },
+  "gitzone": {
+    "projectType": "npm",
+    "module": {
+      "githost": "gitlab.com",
+      "gitscope": "pushrocks",
+      "gitrepo": "taskbuffer",
+      "shortDescription": "flexible task management. TypeScript ready!",
+      "npmPackagename": "@pushrocks/taskbuffer",
+      "license": "MIT"
+    }
  }
 }
--- a/package-lock.json
+++ b/package-lock.json
--- a/package.json
+++ b/package.json
@ -1,40 +1,62 @@
 {
-  "name": "taskbuffer",
-  "version": "1.0.1",
-  "description": "Flexible task organization for gulp. TypeScript ready!",
-  "main": "dist/index.js",
-  "typings": "dist/index.d.ts",
+  "name": "@pushrocks/taskbuffer",
+  "version": "2.1.15",
+  "private": false,
+  "description": "flexible task management. TypeScript ready!",
+  "main": "dist_ts/index.js",
+  "typings": "dist_ts/index.d.ts",
  "scripts": {
-    "test": "(npmts)"
+    "test": "(tstest test/ --web)",
+    "build": "(tsbuild --web && tsbundle npm)"
  },
  "repository": {
    "type": "git",
-    "url": "git+https://github.com/pushrocks/taskbuffer.git"
+    "url": "git+https://gitlab.com/pushrocks/taskbuffer.git"
  },
  "keywords": [
    "gulp",
-    "tasks",
-    "watch",
-    "buffer"
+    "task",
+    "buffer",
+    "TypeScript",
+    "push.rocks"
  ],
  "author": "Lossless GmbH",
  "license": "MIT",
  "bugs": {
-    "url": "https://github.com/pushrocks/taskbuffer/issues"
+    "url": "https://gitlab.com/pushrocks/taskbuffer/issues"
  },
-  "homepage": "https://github.com/pushrocks/taskbuffer#readme",
+  "homepage": "https://gitlab.com/pushrocks/taskbuffer#readme",
  "dependencies": {
-    "@types/lodash": "^0.0.28",
-    "@types/q": "^0.0.27",
-    "beautylog": "^5.0.18",
-    "lodash": "^4.14.1",
-    "q": "^1.4.1",
-    "rxjs": "^5.0.0-beta.10",
-    "typings-global": "^1.0.6"
+    "@pushrocks/lik": "^5.0.0",
+    "@pushrocks/smartdelay": "^2.0.13",
+    "@pushrocks/smartlog": "^2.0.44",
+    "@pushrocks/smartpromise": "^3.1.6",
+    "@pushrocks/smartrx": "^2.0.19",
+    "@pushrocks/smarttime": "^3.0.43",
+    "@types/cron": "^1.7.3"
  },
  "devDependencies": {
-    "npmts-g": "^5.2.8",
-    "should": "^10.0.0",
-    "typings-test": "^1.0.1"
-  }
+    "@gitzone/tsbuild": "^2.1.28",
+    "@gitzone/tsbundle": "^1.0.88",
+    "@gitzone/tstest": "^1.0.60",
+    "@pushrocks/tapbundle": "^3.2.14",
+    "@types/node": "^16.11.7",
+    "tslint": "^6.1.3",
+    "tslint-config-prettier": "^1.18.0"
+  },
+  "files": [
+    "ts/**/*",
+    "ts_web/**/*",
+    "dist/**/*",
+    "dist_*/**/*",
+    "dist_ts/**/*",
+    "dist_ts_web/**/*",
+    "assets/**/*",
+    "cli.js",
+    "npmextra.json",
+    "readme.md"
+  ],
+  "browserslist": [
+    "last 1 chrome versions"
+  ]
 }
--- a/readme.md
+++ b/readme.md
@ -0,0 +1,63 @@
+# @pushrocks/taskbuffer
+flexible task management. TypeScript ready!
+
+## Availabililty and Links
+* [npmjs.org (npm package)](https://www.npmjs.com/package/@pushrocks/taskbuffer)
+* [gitlab.com (source)](https://gitlab.com/pushrocks/taskbuffer)
+* [github.com (source mirror)](https://github.com/pushrocks/taskbuffer)
+* [docs (typedoc)](https://pushrocks.gitlab.io/taskbuffer/)
+
+## Status for master
+
+Status Category | Status Badge
+-- | --
+GitLab Pipelines | [![pipeline status](https://gitlab.com/pushrocks/taskbuffer/badges/master/pipeline.svg)](https://lossless.cloud)
+GitLab Pipline Test Coverage | [![coverage report](https://gitlab.com/pushrocks/taskbuffer/badges/master/coverage.svg)](https://lossless.cloud)
+npm | [![npm downloads per month](https://badgen.net/npm/dy/@pushrocks/taskbuffer)](https://lossless.cloud)
+Snyk | [![Known Vulnerabilities](https://badgen.net/snyk/pushrocks/taskbuffer)](https://lossless.cloud)
+TypeScript Support | [![TypeScript](https://badgen.net/badge/TypeScript/>=%203.x/blue?icon=typescript)](https://lossless.cloud)
+node Support | [![node](https://img.shields.io/badge/node->=%2010.x.x-blue.svg)](https://nodejs.org/dist/latest-v10.x/docs/api/)
+Code Style | [![Code Style](https://badgen.net/badge/style/prettier/purple)](https://lossless.cloud)
+PackagePhobia (total standalone install weight) | [![PackagePhobia](https://badgen.net/packagephobia/install/@pushrocks/taskbuffer)](https://lossless.cloud)
+PackagePhobia (package size on registry) | [![PackagePhobia](https://badgen.net/packagephobia/publish/@pushrocks/taskbuffer)](https://lossless.cloud)
+BundlePhobia (total size when bundled) | [![BundlePhobia](https://badgen.net/bundlephobia/minzip/@pushrocks/taskbuffer)](https://lossless.cloud)
+Platform support | [![Supports Windows 10](https://badgen.net/badge/supports%20Windows%2010/yes/green?icon=windows)](https://lossless.cloud) [![Supports Mac OS X](https://badgen.net/badge/supports%20Mac%20OS%20X/yes/green?icon=apple)](https://lossless.cloud)
+
+## Usage
+
+We highly recommend TypeScript as this module supports **TypeScript intellisense**.
+
+```javascript
+import * as taskbuffer from "taskbuffer";
+
+myTask = new taskbuffer.Task({
+  preTask: someOtherTask // optional, don't worry loops are prevented
+  afterTask: someOtherTask // optional, don't worry loops are prevented
+  name:"myTask1",
+  buffered: true, // optional
+  bufferMax: 3, // optional, call qeues greater than this are truncated
+  execDelay: 1000, // optional, time in ms to wait before executing task call
+  taskFunction:() => {
+    // do some stuff and return promise
+    // pass on any data through promise resolution
+    // Use TypeScript for better understanding and code completion
+  }
+})
+```
+
+For further information read the linked docs at the top of this README.
+
+> MIT licensed | **&copy;** [Lossless GmbH](https://lossless.gmbh)
+
+[![repo-footer](https://pushrocks.gitlab.io/assets/repo-footer.svg)](https://push.rocks)
+
+## Contribution
+
+We are always happy for code contributions. If you are not the code contributing type that is ok. Still, maintaining Open Source repositories takes considerable time and thought. If you like the quality of what we do and our modules are useful to you we would appreciate a little monthly contribution: You can [contribute one time](https://lossless.link/contribute-onetime) or [contribute monthly](https://lossless.link/contribute). :)
+
+For further information read the linked docs at the top of this readme.
+
+> MIT licensed | **&copy;** [Lossless GmbH](https://lossless.gmbh)
+| By using this npm module you agree to our [privacy policy](https://lossless.gmbH/privacy)
+
+[![repo-footer](https://lossless.gitlab.io/publicrelations/repofooter.svg)](https://maintainedby.lossless.com)
--- a/test/test.1.task.ts
+++ b/test/test.1.task.ts
@ -0,0 +1,115 @@
+import { expect, tap } from '@pushrocks/tapbundle';
+import taskbuffer = require('../ts/index');
+
+import * as smartpromise from '@pushrocks/smartpromise';
+import * as smartdelay from '@pushrocks/smartdelay';
+
+// setup some testData to work with
+let testTask: taskbuffer.Task;
+
+let testPreTask = new taskbuffer.Task({
+  taskFunction: async () => {
+    console.log('preTask executed');
+  },
+  preTask: testTask,
+});
+
+// some more tasks to test with
+let task1Counter = 0; // how often task 1 is being executed
+let task1 = new taskbuffer.Task({
+  name: 'Task 1',
+  taskFunction: () => {
+    let done = smartpromise.defer();
+    console.log('Task1 started');
+    setTimeout(() => {
+      task1Counter++;
+      console.log('Task1 executed');
+      done.resolve();
+    }, 5000);
+    return done.promise;
+  },
+});
+
+let task2 = new taskbuffer.Task({
+  name: 'Task 1',
+  taskFunction: async () => {
+    const done = smartpromise.defer();
+    console.log('Task2 started');
+    setTimeout(() => {
+      console.log('Task2 executed');
+      done.resolve();
+    }, 5000);
+    await done.promise;
+  },
+});
+
+let task3 = new taskbuffer.Task({
+  name: 'Task 3',
+  taskFunction: () => {
+    let done = smartpromise.defer();
+    console.log('Task3 started');
+    setTimeout(() => {
+      console.log('Task3 executed');
+      done.resolve();
+    }, 5000);
+    return done.promise;
+  },
+});
+
+tap.test('new Task() should return a new task', async () => {
+  testTask = new taskbuffer.Task({
+    taskFunction: async () => {
+      console.log('executed twice');
+    },
+    preTask: testPreTask,
+  });
+});
+
+tap.test('expect testTask to be an instance of Task', async () => {
+  expect(testTask).to.be.instanceof(taskbuffer.Task);
+});
+
+tap.test('expect testTask.idle is true', async () => {
+  if (!testTask.idle) {
+    throw new Error('testTask.idle is not true');
+  }
+});
+
+tap.test('testTask.running should be of type boolean and initially false', async () => {
+  expect(testTask.running).to.be.a('boolean');
+  // tslint:disable-next-line:no-unused-expression
+  expect(testTask.running).to.be.false;
+});
+
+tap.test('testTask.trigger() should return Promise', async () => {
+  expect(testTask.trigger()).to.be.instanceof(Promise);
+});
+
+tap.test('testTask.trigger() returned Promise should be fullfilled', async () => {
+  await testTask.trigger();
+});
+
+tap.test('expect to run a task without pre and afterTask errorless', async () => {
+  let localTestTask = new taskbuffer.Task({
+    taskFunction: async () => {
+      console.log('only once');
+    },
+  });
+  await localTestTask.trigger();
+});
+
+tap.test('expect task to run in buffered mode', async () => {
+  let localTestTask = new taskbuffer.Task({
+    taskFunction: async () => {
+      await smartdelay.delayFor(3000);
+    },
+    buffered: true,
+    bufferMax: 2,
+  });
+  localTestTask.trigger();
+  localTestTask.trigger();
+  localTestTask.trigger();
+  await localTestTask.trigger();
+});
+
+tap.start();
--- a/test/test.2.taskchain.ts
+++ b/test/test.2.taskchain.ts
@ -0,0 +1,48 @@
+import { expect, tap } from '@pushrocks/tapbundle';
+import taskbuffer = require('../ts/index');
+
+import * as smartpromise from '@pushrocks/smartpromise';
+import * as smartdelay from '@pushrocks/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).to.be.true;
+  // tslint:disable-next-line:no-unused-expression
+  expect(task2Executed).to.be.false;
+  await smartdelay.delayFor(2100);
+  // tslint:disable-next-line:no-unused-expression
+  expect(task2Executed).to.be.true;
+  await testPromise;
+});
+
+tap.start();
--- a/test/test.3.taskparallel.ts
+++ b/test/test.3.taskparallel.ts
@ -0,0 +1,36 @@
+import { expect, tap } from '@pushrocks/tapbundle';
+import taskbuffer = require('../ts/index');
+import * as smartdelay from '@pushrocks/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 in Parallel', async () => {
+  const testTaskparallel = new taskbuffer.Taskparallel({
+    taskArray: [task1, task2, task3],
+  });
+  await testTaskparallel.trigger();
+});
+
+tap.start();
--- a/test/test.4.taskmanager.both.ts
+++ b/test/test.4.taskmanager.both.ts
@ -0,0 +1,47 @@
+import { expect, tap } from '@pushrocks/tapbundle';
+import taskbuffer = require('../ts/index');
+
+import * as smartpromise from '@pushrocks/smartpromise';
+import * as smartdelay from '@pushrocks/smartdelay';
+
+let myTaskManager: taskbuffer.TaskManager;
+let taskRunCounter = 0;
+const taskDone = smartpromise.defer();
+
+tap.test('should create an instance of TaskManager', async () => {
+  myTaskManager = new taskbuffer.TaskManager();
+  expect(myTaskManager).to.be.instanceof(taskbuffer.TaskManager);
+});
+
+tap.test('should run the task as expected', async () => {
+  let referenceBoolean = false;
+  myTaskManager.addTask(
+    new taskbuffer.Task({
+      name: 'myTask',
+      taskFunction: async () => {
+        console.log('Task executed!');
+        referenceBoolean = true;
+        taskRunCounter++;
+        if (taskRunCounter === 10) {
+          taskDone.resolve();
+        }
+      },
+    })
+  );
+  myTaskManager.start();
+  await myTaskManager.triggerTaskByName('myTask');
+  // tslint:disable-next-line:no-unused-expression
+  expect(referenceBoolean).to.be.true;
+});
+
+tap.test('should schedule task', async () => {
+  myTaskManager.scheduleTaskByName('myTask', '* * * * * *');
+  await taskDone.promise;
+  myTaskManager.descheduleTaskByName('myTask');
+});
+
+tap.test('should stop the taskmanager', async () => {
+  myTaskManager.stop();
+});
+
+tap.start();
--- a/test/test.5.task.paramflow.ts
+++ b/test/test.5.task.paramflow.ts
@ -0,0 +1,64 @@
+import { expect, tap } from '@pushrocks/tapbundle';
+import taskbuffer = require('../ts/index');
+
+import * as smartpromise from '@pushrocks/smartpromise';
+import * as smartdelay from '@pushrocks/smartdelay';
+
+const flowTask1 = new taskbuffer.Task({
+  taskFunction: (x: number) => {
+    const done = smartpromise.defer();
+    console.log('flowTask1');
+    console.log(x);
+    done.resolve(x);
+    return done.promise;
+  },
+});
+
+const flowTaskBuffered = new taskbuffer.Task({
+  taskFunction: (x: number) => {
+    const done = smartpromise.defer();
+    console.log('flowTask1');
+    console.log(x);
+    done.resolve(x);
+    return done.promise;
+  },
+  buffered: true,
+  bufferMax: 1,
+});
+
+const flowTask2 = new taskbuffer.Task({
+  taskFunction: (x: number) => {
+    const done = smartpromise.defer();
+    console.log('flowTask2');
+    console.log(x);
+    done.resolve(x);
+    return done.promise;
+  },
+  preTask: flowTask1,
+});
+
+const flowTask3 = new taskbuffer.Taskchain({
+  taskArray: [flowTask1, flowTask2],
+});
+
+tap.test('should let a value flow through a task', async () => {
+  const result = await flowTask1.trigger(12);
+  expect(result).to.equal(12);
+});
+
+tap.test('expect values to flow between tasks', async () => {
+  const result = await flowTask2.trigger(12);
+  expect(result).to.equal(12);
+});
+
+tap.test('expect values to flow between tasks when buffered', async () => {
+  const result = await flowTaskBuffered.trigger(12);
+  expect(result).to.equal(12);
+});
+
+tap.test('expect values to flow between tasks in Taskchain', async () => {
+  const result = await flowTask3.trigger(12);
+  expect(result).to.equal(12);
+});
+
+tap.start();
--- a/test/test.6.taskonce.ts
+++ b/test/test.6.taskonce.ts
@ -0,0 +1,28 @@
+import { expect, tap } from '@pushrocks/tapbundle';
+
+import * as taskbuffer from '../ts/index';
+
+let myNumber = 0;
+let myTaskOnce: taskbuffer.TaskOnce;
+
+tap.test('should create a valid instance of TaskOnce', async () => {
+  myTaskOnce = new taskbuffer.TaskOnce({
+    taskFunction: async () => {
+      myNumber++;
+    },
+  });
+  expect(myTaskOnce).to.be.instanceof(taskbuffer.TaskOnce);
+});
+
+tap.test('myNumber should still be 0', async () => {
+  expect(myNumber).to.equal(0);
+});
+
+tap.test('myTaskOnce should trigger once', async () => {
+  await myTaskOnce.trigger();
+  await myTaskOnce.trigger();
+  await myTaskOnce.trigger();
+  expect(myNumber).to.equal(1);
+});
+
+tap.start();
--- a/test/test.7.taskloop.ts
+++ b/test/test.7.taskloop.ts
@ -0,0 +1,51 @@
+import { tap, expect } from '@pushrocks/tapbundle';
+
+import * as taskbuffer from '../ts';
+
+let preTask: taskbuffer.Task;
+let afterTask: taskbuffer.Task;
+
+let mainTask: taskbuffer.Task;
+
+tap.test('should create tasks', async () => {
+  preTask = new taskbuffer.Task({
+    name: 'myPreTask',
+    taskFunction: async () => {
+      console.log('pretask executed :)');
+      return 'hi';
+    },
+  });
+  afterTask = new taskbuffer.Task({
+    name: 'myAfterTask',
+    taskFunction: async (x) => {
+      if (x === 'hi') {
+        console.log('afterTask: values get passed along alright');
+      }
+      console.log('afterTask executed :)');
+      return x;
+    },
+    preTask,
+    afterTask,
+  });
+
+  mainTask = new taskbuffer.Task({
+    name: 'mainTask',
+    taskFunction: async (x) => {
+      if (x === 'hi') {
+        console.log('mainTask: values get passed along alright');
+      }
+      console.log('afterTask executed :)');
+      return x;
+    },
+    preTask: () => {
+      return preTask;
+    },
+    afterTask,
+  });
+});
+
+tap.test('should execute the mainTask', async () => {
+  await mainTask.trigger();
+});
+
+tap.start();
--- a/test/test.8.bufferedrun.ts
+++ b/test/test.8.bufferedrun.ts
@ -0,0 +1,52 @@
+import { tap, expect } from '@pushrocks/tapbundle';
+
+import * as taskbuffer from '../ts';
+
+let counter1 = 0;
+let counter2 = 0;
+let counter3 = 0;
+
+tap.test('should run buffered', async (tools) => {
+  const task = new taskbuffer.Task({
+    name: 'a buffered task',
+    taskFunction: async () => {
+      counter1++;
+      await tools.delayFor(2000);
+      console.log(`task 1 ran ${counter1} times`);
+    },
+    buffered: true,
+    bufferMax: 1,
+    afterTask: () => {
+      return task2;
+    }
+  });
+  const task2 = new taskbuffer.Task({
+    name: 'a buffered task',
+    taskFunction: async () => {
+      counter2++;
+      await tools.delayFor(2000);
+      console.log(`task2 ran ${counter2} times`);
+    },
+    buffered: true,
+    bufferMax: 1,
+    afterTask: () => {
+      return task3;
+    }
+  });
+  const task3 = new taskbuffer.Task({
+    name: 'a buffered task',
+    taskFunction: async () => {
+      counter3++;
+      await tools.delayFor(2000);
+      console.log(`task3 ran ${counter3} times`);
+    },
+    buffered: true,
+    bufferMax: 1
+  });
+  while(counter1 < 10) {
+    await tools.delayFor(5000);
+    task.trigger();
+  }
+})
+
+tap.start();
--- a/test/test.d.ts
+++ b/test/test.d.ts
@ -1 +0,0 @@
-import "typings-test";
--- a/test/test.js
+++ b/test/test.js
--- a/test/test.taskrunner.ts
+++ b/test/test.taskrunner.ts
@ -0,0 +1,33 @@
+import { tap, expect } from '@pushrocks/tapbundle';
+import * as taskbuffer from '../ts/index';
+
+let testTaskRunner: taskbuffer.TaskRunner;
+
+tap.test('should create a valid taskrunner', async () => {
+  testTaskRunner = new taskbuffer.TaskRunner();
+  await testTaskRunner.start();
+});
+
+tap.test('should execute task when its scheduled', async (tools) => {
+  const done = tools.defer();
+  testTaskRunner.addTask(
+    new taskbuffer.Task({
+      taskFunction: async () => {
+        console.log('hi');
+      },
+    })
+  );
+
+  testTaskRunner.addTask(
+    new taskbuffer.Task({
+      taskFunction: async () => {
+        console.log('there');
+        done.resolve();
+      },
+    })
+  );
+
+  await done.promise;
+});
+
+tap.start();
--- a/test/test.ts
+++ b/test/test.ts
@ -1,130 +0,0 @@
-import "typings-test";
-import taskbuffer = require("../dist/index");
-let should = require("should");
-import q = require("q")
-
-// setup some testData to work with
-let testTask:taskbuffer.Task;
-let testTaskFunction = function(){
-    let done = q.defer();
-    console.log("main function executed!")
-    done.resolve();
-    return done.promise;
-}
-let testPreTask = new taskbuffer.Task({
-    taskFunction:function(){
-        let done = q.defer();
-        console.log("preTask executed");
-        done.resolve();
-        return done.promise;
-    },
-    preTask:testTask
-});
-
-describe("taskbuffer",function(){
-    describe(".Task",function(){
-        it("new Task() should return a new task",function(){
-            testTask = new taskbuffer.Task({taskFunction:testTaskFunction,preTask:testPreTask});
-        });
-        it("testTask should be and instance of Task",function(){
-            testTask.should.be.instanceof(taskbuffer.Task);
-        });
-        it("testTask.idle is true",function(){
-            if (!testTask.idle){
-                throw new Error("testTask.idle is not true");
-            }
-            
-        });
-        it("testTask.running is type boolean and initially false",function(){
-            testTask.running.should.be.type("boolean");
-            testTask.running.should.be.false();
-        });
-        it("testTask.trigger() should return Promise",function(){
-            testTask.trigger().should.be.Promise();
-        });
-        it("testTask.trigger() returned Promise should be fullfilled",function(done){
-            testTask.trigger()
-                .then(done);
-        });
-        it("should run a task without pre and afterTask",function(done){
-            let localTestTask = new taskbuffer.Task({taskFunction:testTaskFunction});
-            localTestTask.trigger().then(done);
-        });
-    });
-    describe("Taskchain",function(){
-        let testTaskchain;
-        let testTaskArray = [
-            new taskbuffer.Task({
-                name:"task1",
-                taskFunction:function(){
-                    let done = q.defer();
-                    setTimeout(done.resolve,2000);
-                    return done.promise;
-                }
-            }),
-            new taskbuffer.Task({
-                name:"task2",
-                taskFunction: function(){
-                    let done = q.defer();
-                    setTimeout(done.resolve,2000);
-                    return done.promise;
-                }
-            }),
-        ];
-        it("should run tasks in sequence",function(done){
-            this.timeout(5000);
-            testTaskchain = new taskbuffer.Taskchain({
-                name:"Taskchain1",
-                taskArray:testTaskArray
-            });
-            testTaskchain.trigger().then(done);
-        });
-    });
-    describe("taskparallel",function(){
-        let task1 = new taskbuffer.Task({
-            name:"Task 1",
-            taskFunction: () => {
-                let done = q.defer();
-                console.log("Task1 started");
-                setTimeout(() => {
-                    console.log("Task1 executed");
-                    done.resolve();
-                },5000)
-                return done.promise;
-            }
-        });
-        let task2 = new taskbuffer.Task({
-            name:"Task 1",
-            taskFunction: () => {
-                let done = q.defer();
-                console.log("Task2 started");
-                setTimeout(() => {
-                    console.log("Task2 executed");
-                    done.resolve();
-                },5000)
-                return done.promise;
-            }
-        });
-        let task3 = new taskbuffer.Task({
-            name:"Task 3",
-            taskFunction: () => {
-                let done = q.defer();
-                console.log("Task3 started");
-                setTimeout(() => {
-                    console.log("Task3 executed");
-                    done.resolve();
-                },5000)
-                return done.promise;
-            }
-        });
-        it("should run in Parallel",function(done){
-            this.timeout("7000");
-            let testTaskparallel = new taskbuffer.Taskparallel({
-                taskArray:[task1,task2,task3]
-            });
-            testTaskparallel.trigger().then(() => {
-                done();
-            });
-        })
-    })
-});
--- a/ts/index.ts
+++ b/ts/index.ts
@ -1,7 +1,7 @@
-export {Task,ITaskFunction} from "./taskbuffer.classes.task";
-export {Taskchain} from "./taskbuffer.classes.taskchain";
-export {Taskparallel} from "./taskbuffer.classes.taskparallel";
-export {Taskspace} from "./taskbuffer.classes.taskspace";
-
-// import for naming only
-import "./taskbuffer.classes.helpers"
+export { Task, ITaskFunction } from './taskbuffer.classes.task';
+export { Taskchain } from './taskbuffer.classes.taskchain';
+export { Taskparallel } from './taskbuffer.classes.taskparallel';
+export { TaskManager } from './taskbuffer.classes.taskmanager';
+export { TaskOnce } from './taskbuffer.classes.taskonce';
+export { TaskRunner } from './taskbuffer.classes.taskrunner';
+export { TaskDebounced } from './taskbuffer.classes.taskdebounced';
--- a/ts/taskbuffer.classes.bufferrunner.ts
+++ b/ts/taskbuffer.classes.bufferrunner.ts
@ -0,0 +1,39 @@
+import { Task } from './taskbuffer.classes.task';
+
+export class BufferRunner {
+  public task: Task;
+  // initialze by default
+  public bufferCounter: number = 0;
+  constructor(taskArg: Task) {
+    this.task = taskArg;
+  }
+
+  public trigger(x: any): Promise<any> {
+    if (!(this.bufferCounter >= this.task.bufferMax)) {
+      this.bufferCounter++;
+    }
+    const returnPromise: Promise<any> = this.task.cycleCounter.getPromiseForCycle(
+      this.bufferCounter + 1
+    );
+    if (!this.task.running) {
+      this._run(x);
+    }
+    return returnPromise;
+  }
+
+  private _run(x: any) {
+    const recursiveBufferRunner = (x: any) => {
+      if (this.bufferCounter >= 0) {
+        this.task.running = true;
+        Task.runTask(this.task, { x: x }).then((x) => {
+          this.bufferCounter--; // this.bufferCounter drops below 0, the recursion stops.
+          this.task.cycleCounter.informOfCycle(x);
+          recursiveBufferRunner(x);
+        });
+      } else {
+        this.task.running = false;
+      }
+    };
+    recursiveBufferRunner(x);
+  }
+}
--- a/ts/taskbuffer.classes.cyclecounter.ts
+++ b/ts/taskbuffer.classes.cyclecounter.ts
@ -0,0 +1,36 @@
+import * as plugins from './taskbuffer.plugins';
+import { Task } from './taskbuffer.classes.task';
+
+export interface ICycleObject {
+  cycleCounter: number;
+  deferred: plugins.smartpromise.Deferred<any>;
+}
+
+export class CycleCounter {
+  public task: Task;
+  public cycleObjectArray: ICycleObject[] = [];
+  constructor(taskArg: Task) {
+    this.task = taskArg;
+  }
+  public getPromiseForCycle(cycleCountArg: number) {
+    const done = plugins.smartpromise.defer();
+    const cycleObject: ICycleObject = {
+      cycleCounter: cycleCountArg,
+      deferred: done,
+    };
+    this.cycleObjectArray.push(cycleObject);
+    return done.promise;
+  }
+  public informOfCycle(x: any) {
+    const newCycleObjectArray: ICycleObject[] = [];
+    this.cycleObjectArray.forEach((cycleObjectArg) => {
+      cycleObjectArg.cycleCounter--;
+      if (cycleObjectArg.cycleCounter <= 0) {
+        cycleObjectArg.deferred.resolve(x);
+      } else {
+        newCycleObjectArray.push(cycleObjectArg);
+      }
+    });
+    this.cycleObjectArray = newCycleObjectArray;
+  }
+}
--- a/ts/taskbuffer.classes.helpers.ts
+++ b/ts/taskbuffer.classes.helpers.ts
@ -1,84 +0,0 @@
-import plugins = require("./taskbuffer.plugins");
-import {Task,ITaskFunction} from "./taskbuffer.classes.task";
-
-export let emptyTaskFunction:ITaskFunction = function(){
-    let done = plugins.Q.defer();
-    done.resolve();
-    return done.promise;
-};
-
-export let isTask = function(taskArg):boolean{
-    if(
-        taskArg instanceof Task
-        && typeof taskArg.task === "function"
-    ){
-        return true;
-    } else {
-        return false;
-    }
-};
-
-
-export let isTaskTouched = (taskArg:Task, touchedTasksArray:Task[]):boolean => {
-    let result = false;
-    for (let keyArg in touchedTasksArray){
-        if(taskArg === touchedTasksArray[keyArg]){
-            result = true;
-        }
-    }
-    return result;
-}
-
-export let runTask = function(taskArg:Task,optionsArg:{touchedTasksArray:Task[]} = {touchedTasksArray:[]}){
-    let done = plugins.Q.defer();
-    taskArg.running = true;
-    done.promise.then(function(){taskArg.running = false});
-    let localDeferred = plugins.Q.defer();
-    let touchedTasksArray:Task[];
-    if(optionsArg.touchedTasksArray){
-        touchedTasksArray = optionsArg.touchedTasksArray;
-    } else {
-        touchedTasksArray = [];
-    }
-    touchedTasksArray.push(taskArg);
-    localDeferred.promise
-        .then(() =>{
-            if(taskArg.preTask && !isTaskTouched(taskArg.preTask,touchedTasksArray)){
-                return runTask(taskArg.preTask,{touchedTasksArray:touchedTasksArray})
-            } else {
-                let done2 = plugins.Q.defer();
-                done2.resolve();
-                return done2.promise;
-            }
-        })
-        .then(() => {
-            return taskArg.task();
-        })
-        .then(() => {
-            if(taskArg.afterTask && !isTaskTouched(taskArg.afterTask,touchedTasksArray)){
-                return runTask(taskArg.afterTask,{touchedTasksArray:touchedTasksArray})
-            } else {
-                let done2 = plugins.Q.defer();
-                done2.resolve();
-                return done2.promise;
-            }
-        })
-        .then(() => {
-            done.resolve();
-        });
-    localDeferred.resolve();
-    return done.promise;
-};
-
-export let runBufferedTask = (taskArg:Task) => {
-    let recursiveBufferRunner = () => {
-        if(taskArg.bufferCounter > 0){
-            taskArg.runningBuffered = true;
-            taskArg.bufferCounter--;
-            runTask(taskArg)
-                .then(recursiveBufferRunner);
-        } else {
-            taskArg.runningBuffered = false;
-        }
-    }
-};
--- a/ts/taskbuffer.classes.task.ts
+++ b/ts/taskbuffer.classes.task.ts
@ -1,89 +1,228 @@
-import * as plugins from "./taskbuffer.plugins"
-import * as helpers from "./taskbuffer.classes.helpers"
+import * as plugins from './taskbuffer.plugins';
+import { BufferRunner } from './taskbuffer.classes.bufferrunner';
+import { CycleCounter } from './taskbuffer.classes.cyclecounter';

+import { logger } from './taskbuffer.logging';

 export interface ITaskFunction {
-    ():PromiseLike<any>;
+  (x?: any): PromiseLike<any>;
 }

+export type TPreOrAfterTaskFunction = () => Task;
+
 export class Task {
-    name:string;
-    task:any;
-    running:boolean = false;
-    runningBuffered:boolean = false;
-    idle:boolean = true;
-    buffered:boolean = false;
-    bufferCounter:number;
-    bufferMax:number = 1;
-    private _counterTriggerAbsolute:number = 0;
-    private _state:string;
-    preTask:Task;
-    afterTask:Task;
-
-    constructor(optionsArg:{
-        taskFunction:ITaskFunction,
-        preTask?:Task,
-        afterTask?:Task,
-        buffered?:boolean,
-        bufferMax?:number,
-        name?:string
-    }){
-        var options = optionsArg;
-        this.task = optionsArg.taskFunction;
-        this.preTask = options.preTask;
-        this.afterTask = options.afterTask;
-        this.running = false;
-        this.idle = !this.running && !this.runningBuffered;
-        this.buffered = options.buffered;
-        this.bufferMax = options.bufferMax;
-        this.name = options.name;
+  // STATIC
+  public static extractTask(preOrAfterTaskArg: Task | TPreOrAfterTaskFunction): Task {
+    switch (true) {
+      case !preOrAfterTaskArg:
+        return null;
+      case preOrAfterTaskArg instanceof Task:
+        return preOrAfterTaskArg as Task;
+      case typeof preOrAfterTaskArg === 'function':
+        const taskFunction = preOrAfterTaskArg as TPreOrAfterTaskFunction;
+        return taskFunction();
+      default:
+        return null;
    }
-    
-    /**
-     * trigger the task. Will trigger buffered if this.buffered is true
-     */
-    trigger(){
-        let done = plugins.Q.defer();
-        if(this.buffered) {
-            this.triggerBuffered()
-                .then(done.resolve);
-        }
-        else {
-            this.triggerUnBuffered()
-                .then(done.resolve);
-        };
-        return done.promise;
+  }
+
+  public static emptyTaskFunction: ITaskFunction = function (x) {
+    const done = plugins.smartpromise.defer();
+    done.resolve();
+    return done.promise;
+  };
+
+  public static isTask = (taskArg: Task): boolean => {
+    if (taskArg instanceof Task && typeof taskArg.taskFunction === 'function') {
+      return true;
+    } else {
+      return false;
+    }
+  };
+
+  public static isTaskTouched = (
+    taskArg: Task | TPreOrAfterTaskFunction,
+    touchedTasksArray: Task[]
+  ): boolean => {
+    const taskToCheck = Task.extractTask(taskArg);
+    let result = false;
+    for (const keyArg in touchedTasksArray) {
+      if (taskToCheck === touchedTasksArray[keyArg]) {
+        result = true;
+      }
+    }
+    return result;
+  };
+
+  public static runTask = async (
+    taskArg: Task | TPreOrAfterTaskFunction,
+    optionsArg: { x?: any; touchedTasksArray?: Task[] }
+  ) => {
+    const taskToRun = Task.extractTask(taskArg);
+    const done = plugins.smartpromise.defer();
+
+    // pay respect to execDelay
+    if (taskToRun.execDelay) {
+      await plugins.smartdelay.delayFor(taskToRun.execDelay);
+    }
+
+    //  set running params
+    taskToRun.running = true;
+
+    done.promise.then(async () => {
+      taskToRun.running = false;
+    });
+
+    // handle options
+    const options = {
+      ...{ x: undefined, touchedTasksArray: [] },
+      ...optionsArg,
    };
+    const x = options.x;
+    const touchedTasksArray: Task[] = options.touchedTasksArray;

-    /**
-     * trigger task unbuffered.
-     */
-    triggerUnBuffered(){
-        return helpers.runTask(this);
-    }
-    
-    /**
-     * trigger task buffered.
-     */
-    triggerBuffered(){
-        var done = plugins.Q.defer();
-        if(!(this.bufferCounter >= this.bufferMax)){
-            this.bufferCounter++
-        };
-        if(!this.runningBuffered){
-            helpers.runBufferedTask(this);
-        };
-        return done.promise;
-    }
+    touchedTasksArray.push(taskToRun);

-    get state():string {
-        return this._state;
-    }
-    set state(stateArg:string){
-        if (stateArg == "locked"){
-            this._state = "locked";
+    // run the task cascade
+    const localDeferred = plugins.smartpromise.defer();
+    localDeferred.promise
+      .then(() => {
+        // lets run any preTask
+
+        if (taskToRun.preTask && !Task.isTaskTouched(taskToRun.preTask, touchedTasksArray)) {
+          return Task.runTask(taskToRun.preTask, { x, touchedTasksArray });
        } else {
-            plugins.beautylog.error("state type " + stateArg.blue + " could not be set");
+          const done2 = plugins.smartpromise.defer();
+          done2.resolve(x);
+          return done2.promise;
        }
+      })
+      .then(async (x) => {
+        // lets run the main task
+        try {
+          return await taskToRun.taskFunction(x);
+        } catch (e) {
+          console.log(e);
+        }
+      })
+      .then((x) => {
+        if (taskToRun.afterTask && !Task.isTaskTouched(taskToRun.afterTask, touchedTasksArray)) {
+          return Task.runTask(taskToRun.afterTask, { x: x, touchedTasksArray: touchedTasksArray });
+        } else {
+          const done2 = plugins.smartpromise.defer();
+          done2.resolve(x);
+          return done2.promise;
+        }
+      })
+      .then((x) => {
+        done.resolve(x);
+      })
+      .catch((err) => {
+        console.log(err);
+      });
+    localDeferred.resolve();
+    return await done.promise;
+  };
+
+  // INSTANCE
+  // man datory properties
+  public name: string;
+  public taskFunction: ITaskFunction;
+  public buffered: boolean;
+  public cronJob: plugins.smarttime.CronJob;
+
+  public bufferMax: number;
+  public execDelay: number;
+
+  // tasks to run before and after
+  public preTask: Task | TPreOrAfterTaskFunction;
+  public afterTask: Task | TPreOrAfterTaskFunction;
+
+  // initialize by default
+  public running: boolean = false;
+  public bufferRunner = new BufferRunner(this);
+  public cycleCounter = new CycleCounter(this);
+
+  public idle: boolean = true;
+  private _state: string = 'ready';
+
+  constructor(optionsArg: {
+    /**
+     * the task function to run, must return promise
+     */
+    taskFunction: ITaskFunction;
+    /**
+     * any other task to run before
+     */
+    preTask?: Task | TPreOrAfterTaskFunction;
+    /**
+     * any other task to run after
+     */
+    afterTask?: Task | TPreOrAfterTaskFunction;
+    /**
+     * wether this task should run buffered
+     */
+    buffered?: boolean;
+    /**
+     * the maximum buffer
+     */
+    bufferMax?: number;
+    /**
+     * the execution delay, before the task is executed
+     * only makes sense when running in buffered mode
+     */
+    execDelay?: number;
+    /**
+     * the name of the task
+     */
+    name?: string;
+  }) {
+    this.taskFunction = optionsArg.taskFunction;
+    this.preTask = optionsArg.preTask;
+    this.afterTask = optionsArg.afterTask;
+    this.idle = !this.running;
+    this.buffered = optionsArg.buffered;
+    this.bufferMax = optionsArg.bufferMax;
+    this.execDelay = optionsArg.execDelay;
+    this.name = optionsArg.name;
+  }
+
+  /**
+   * trigger the task. Will trigger buffered if this.buffered is true
+   */
+  public trigger(x?: any): Promise<any> {
+    if (this.buffered) {
+      return this.triggerBuffered(x);
+    } else {
+      return this.triggerUnBuffered(x);
    }
-}
+  }
+
+  /**
+   * trigger task unbuffered.
+   * will actually run the task, not considering any buffered limits.
+   */
+  public triggerUnBuffered(x?: any): Promise<any> {
+    return Task.runTask(this, { x: x });
+  }
+
+  /**
+   * trigger task buffered.
+   * note: .trigger() also calls this function
+   */
+  public triggerBuffered(x?: any): Promise<any> {
+    return this.bufferRunner.trigger(x);
+  }
+
+  get state(): string {
+    return this._state;
+  }
+
+  set state(stateArg: string) {
+    if (stateArg === 'locked') {
+      this._state = 'locked';
+    } else {
+      logger.log('error', `state type ${stateArg} could not be set`);
+    }
+  }
+}
--- a/ts/taskbuffer.classes.taskchain.ts
+++ b/ts/taskbuffer.classes.taskchain.ts
@ -1,62 +1,58 @@
-import * as plugins from "./taskbuffer.plugins";
-import {Task} from "./taskbuffer.classes.task";
-import helpers = require("./taskbuffer.classes.helpers");
+// TaskChain chains tasks
+// and extends Task
+
+import * as plugins from './taskbuffer.plugins';
+import { Task } from './taskbuffer.classes.task';
+import { logger } from './taskbuffer.logging';

 export class Taskchain extends Task {
-    taskArray:Task[];
-    private _oraObject:plugins.beautylog.Ora;
-    constructor(optionsArg:{
-        name?:string,
-        log?:boolean,
-        taskArray:Task[]
-    }){
-        let options = plugins.lodash.merge(
-            {
-                name:"unnamed Taskchain",
-                log:false
-            },
-            optionsArg,
-            {
-                taskFunction: () => { // this is the function that gets executed when TaskChain is triggered
-                    let done = plugins.Q.defer(); // this is the starting Deferred object 
-                    let taskCounter = 0;
-                    let iterateTasks = () => {
-                        if(typeof this.taskArray[taskCounter] != "undefined"){
-                            this._oraObject.text(this.name + " running: Task" + this.taskArray[taskCounter].name);
-                            this.taskArray[taskCounter].trigger()
-                                .then(()=>{
-                                    plugins.beautylog.ok(this.taskArray[taskCounter].name);
-                                    taskCounter++;
-                                    iterateTasks();
-                                });     
-                        } else {
-                            this._oraObject.endOk("Taskchain \"" + this.name +  "\" completed successfully");
-                            done.resolve();
-                        }
-                    };
-                    iterateTasks();
-                    return done.promise;
-                }
+  taskArray: Task[];
+  constructor(optionsArg: {
+    taskArray: Task[];
+    name?: string;
+    log?: boolean;
+    buffered?: boolean;
+    bufferMax?: number;
+  }) {
+    const options = {
+      ...{
+        name: 'unnamed Taskchain',
+        log: false,
+      },
+      ...optionsArg,
+      ...{
+        taskFunction: (x: any) => {
+          // this is the function that gets executed when TaskChain is triggered
+          const done = plugins.smartpromise.defer(); // this is the starting Deferred object
+          let taskCounter = 0; // counter for iterating async over the taskArray
+          const iterateTasks = (x: any) => {
+            if (typeof this.taskArray[taskCounter] !== 'undefined') {
+              console.log(this.name + ' running: Task' + this.taskArray[taskCounter].name);
+              this.taskArray[taskCounter].trigger(x).then((x) => {
+                logger.log('info', this.taskArray[taskCounter].name);
+                taskCounter++;
+                iterateTasks(x);
+              });
+            } else {
+              console.log('Taskchain "' + this.name + '" completed successfully');
+              done.resolve(x);
            }
-        );
-        super(options);
-        this.taskArray = optionsArg.taskArray;
-        this._oraObject = new plugins.beautylog.Ora("Taskchain idle","blue");
-        if(optionsArg.log === true){
-            this._oraObject.start();
-        };
-    }
-    addTask(taskArg:Task){
-        this.taskArray.push(taskArg);
+          };
+          iterateTasks(x);
+          return done.promise;
+        },
+      },
    };
-    removeTask(taskArg:Task){
-        //TODO
-    };
-    shiftTask(){
-        
-    };
-    trigger(){
-        this._oraObject.start(this.name + " running...");
-        return helpers.runTask(this);
-    }
-};
+    super(options);
+    this.taskArray = optionsArg.taskArray;
+  }
+  addTask(taskArg: Task) {
+    this.taskArray.push(taskArg);
+  }
+  removeTask(taskArg: Task) {
+    // TODO:
+  }
+  shiftTask() {
+    // TODO:
+  }
+}
--- a/ts/taskbuffer.classes.taskdebounced.ts
+++ b/ts/taskbuffer.classes.taskdebounced.ts
@ -0,0 +1,27 @@
+import * as plugins from './taskbuffer.plugins';
+
+import { Task, ITaskFunction } from './taskbuffer.classes.task';
+
+export class TaskDebounced<T = unknown> extends Task {
+  private _debouncedTaskFunction: ITaskFunction;
+  private _observableIntake = new plugins.smartrx.ObservableIntake<T>();
+
+  constructor(optionsArg: {
+    name: string;
+    taskFunction: ITaskFunction;
+    debounceTimeInMillis: number;
+  }) {
+    super({
+      name: optionsArg.name,
+      taskFunction: async (x: T) => {
+        this._observableIntake.push(x);
+      },
+    });
+    this.taskFunction = optionsArg.taskFunction;
+    this._observableIntake.observable
+      .pipe(plugins.smartrx.rxjs.ops.debounceTime(optionsArg.debounceTimeInMillis))
+      .subscribe((x) => {
+        this.taskFunction(x);
+      });
+  }
+}
--- a/ts/taskbuffer.classes.taskmanager.ts
+++ b/ts/taskbuffer.classes.taskmanager.ts
@ -0,0 +1,119 @@
+import * as plugins from './taskbuffer.plugins';
+import { Task } from './taskbuffer.classes.task';
+import { threadId } from 'worker_threads';
+
+export interface ICronJob {
+  cronString: string;
+  taskNameArg: string;
+  job: any;
+}
+
+export class TaskManager {
+  public taskMap = new plugins.lik.ObjectMap<Task>();
+  private cronJobManager = new plugins.smarttime.CronManager();
+
+  constructor() {
+    // nothing here
+  }
+
+  /**
+   * checks if a task is already present
+   * @param taskNameArg
+   */
+  public getTaskByName(taskNameArg: string): Task {
+    return this.taskMap.findSync((itemArg) => {
+      return itemArg.name === taskNameArg;
+    });
+  }
+
+  /**
+   * adds a Task to the TaskManager
+   * @param taskArg
+   */
+  public addTask(taskArg: Task): void {
+    if (!taskArg.name) {
+      throw new Error('taskArg needs a name to be added to taskManager');
+    }
+    this.taskMap.add(taskArg);
+  }
+
+  /**
+   * adds and schedules a task at once
+   * @param taskArg
+   * @param cronStringArg
+   */
+  public addAndScheduleTask(taskArg: Task, cronStringArg: string) {
+    this.addTask(taskArg);
+    this.scheduleTaskByName(taskArg.name, cronStringArg);
+  }
+
+  /**
+   * triggers a task in the TaskManagerByName
+   * @param taskNameArg
+   */
+  public triggerTaskByName(taskNameArg: string): Promise<any> {
+    const taskToTrigger = this.getTaskByName(taskNameArg);
+    if (!taskToTrigger) {
+      throw new Error(`There is no task with the name of ${taskNameArg}`);
+    }
+    return taskToTrigger.trigger();
+  }
+
+  public async triggerTask(task: Task) {
+    return task.trigger();
+  }
+
+  /**
+   * schedules the task by name
+   * @param taskNameArg
+   */
+  public scheduleTaskByName(taskNameArg: string, cronStringArg: string) {
+    const taskToSchedule = this.getTaskByName(taskNameArg);
+    const cronJob = this.cronJobManager.addCronjob(cronStringArg, async () => {
+      await taskToSchedule.triggerBuffered();
+    });
+    taskToSchedule.cronJob = cronJob;
+  }
+
+  /**
+   * deschedules a task by name
+   * @param taskNameArg
+   */
+  public descheduleTaskByName(taskNameArg: string) {
+    const taskToDeSchedule = this.getTaskByName(taskNameArg);
+    if (taskToDeSchedule.cronJob) {
+      this.cronJobManager.removeCronjob(taskToDeSchedule.cronJob);
+      taskToDeSchedule.cronJob = null;
+    }
+    if (this.cronJobManager.cronjobs.isEmpty) {
+      this.cronJobManager.stop();
+    }
+  }
+
+  /**
+   * deschedules a task
+   * @param task
+   */
+  public async descheduleTask(task: Task) {
+    await this.descheduleTaskByName(task.name);
+  }
+  /**
+   * returns all schedules of a specific task
+   * @param taskNameArg
+   */
+  public getSchedulesForTaskName(taskNameArg: string) {}
+
+  /**
+   * starts the taskmanager
+   */
+  public start() {
+    this.cronJobManager.start();
+  }
+
+  /**
+   * stops the taskmanager
+   */
+  public stop() {
+    this.cronJobManager.stop();
+  }
+}
--- a/ts/taskbuffer.classes.taskonce.ts
+++ b/ts/taskbuffer.classes.taskonce.ts
@ -0,0 +1,21 @@
+import * as plugins from './taskbuffer.plugins';
+
+import { Task, ITaskFunction } from './taskbuffer.classes.task';
+
+/**
+ * TaskOnce is run exactly once, no matter how often it is triggered
+ */
+export class TaskOnce extends Task {
+  hasTriggered: boolean = false;
+  constructor(optionsArg: { name?: string; taskFunction: ITaskFunction }) {
+    super({
+      name: optionsArg.name,
+      taskFunction: async () => {
+        if (!this.hasTriggered) {
+          this.hasTriggered = true;
+          await optionsArg.taskFunction();
+        }
+      },
+    });
+  }
+}
--- a/ts/taskbuffer.classes.taskparallel.ts
+++ b/ts/taskbuffer.classes.taskparallel.ts
@ -1,29 +1,24 @@
-import * as plugins from "./taskbuffer.plugins"
-import * as helpers from "./taskbuffer.classes.helpers"
-import { Task } from "./taskbuffer.classes.task"
+import * as plugins from './taskbuffer.plugins';
+import { Task } from './taskbuffer.classes.task';

 export class Taskparallel extends Task {
-    taskArray: Task[];
-    constructor(optionsArg: {
-        taskArray: Task[]
-    }){
-        let options = plugins.lodash.merge(
-            optionsArg,
-            {
-                taskFunction: () => {
-                    let done = plugins.Q.defer();
-                    let promiseArray:PromiseLike<any>[] = []; // stores promises of all tasks, since they run in parallel
-                    this.taskArray.forEach(function (taskArg) {
-                        promiseArray.push(taskArg.trigger());
-                    })
-                    plugins.Q.all(promiseArray)
-                        .then(done.resolve);
-                    return done.promise;
-                }
-            }
-        );
-        super(options);
-        this.taskArray = optionsArg.taskArray;
-    }
+  public taskArray: Task[];
+  constructor(optionsArg: { taskArray: Task[] }) {
+    const options = {
+      ...optionsArg,
+      ...{
+        taskFunction: () => {
+          const done = plugins.smartpromise.defer();
+          const promiseArray: Promise<any>[] = []; // stores promises of all tasks, since they run in parallel
+          this.taskArray.forEach(function (taskArg) {
+            promiseArray.push(taskArg.trigger());
+          });
+          Promise.all(promiseArray).then(done.resolve);
+          return done.promise;
+        },
+      },
+    };
+    super(options);
+    this.taskArray = optionsArg.taskArray;
+  }
 }
-
--- a/ts/taskbuffer.classes.taskrunner.ts
+++ b/ts/taskbuffer.classes.taskrunner.ts
@ -0,0 +1,63 @@
+import * as plugins from './taskbuffer.plugins';
+
+import { Task } from './taskbuffer.classes.task';
+
+export class TaskRunner {
+  public maxParrallelJobs: number = 1;
+  public status: 'stopped' | 'running' = 'stopped';
+  public runningTasks: plugins.lik.ObjectMap<Task> = new plugins.lik.ObjectMap<Task>();
+  public qeuedTasks: Task[] = [];
+
+  constructor() {
+    this.runningTasks.eventSubject.subscribe(async (eventArg) => {
+      this.checkExecution();
+    });
+  }
+
+  /**
+   * adds a task to the qeue
+   */
+  public addTask(taskArg: Task) {
+    this.qeuedTasks.push(taskArg);
+    this.checkExecution();
+  }
+
+  /**
+   * set amount of parallel tasks
+   * be careful, you might loose dependability of tasks
+   */
+  public setMaxParallelJobs(maxParrallelJobsArg: number) {
+    this.maxParrallelJobs = maxParrallelJobsArg;
+  }
+
+  /**
+   * starts the task queue
+   */
+  public async start() {
+    this.status = 'running';
+  }
+
+  /**
+   * checks wether execution is on point
+   */
+  public async checkExecution() {
+    if (
+      this.runningTasks.getArray().length < this.maxParrallelJobs &&
+      this.status === 'running' &&
+      this.qeuedTasks.length > 0
+    ) {
+      const nextJob = this.qeuedTasks.shift();
+      this.runningTasks.add(nextJob);
+      await nextJob.trigger();
+      this.runningTasks.remove(nextJob);
+      this.checkExecution();
+    }
+  }
+
+  /**
+   * stops the task queue
+   */
+  public async stop() {
+    this.status = 'stopped';
+  }
+}
--- a/ts/taskbuffer.classes.taskspace.ts
+++ b/ts/taskbuffer.classes.taskspace.ts
@ -1,6 +0,0 @@
-import * as plugins from "./taskbuffer.plugins"
-import * as helpers from "./taskbuffer.classes.helpers"
-
-export class Taskspace {
-    
-}
--- a/ts/taskbuffer.logging.ts
+++ b/ts/taskbuffer.logging.ts
@ -0,0 +1,3 @@
+import * as plugins from './taskbuffer.plugins';
+
+export const logger = new plugins.smartlog.ConsoleLog();
--- a/ts/taskbuffer.plugins.ts
+++ b/ts/taskbuffer.plugins.ts
@ -1,5 +1,8 @@
-import "typings-global"
-export import beautylog = require("beautylog");
-export import Q = require("q");
-export import lodash= require("lodash");
-export import rxjs = require("rxjs");
+import * as smartlog from '@pushrocks/smartlog';
+import * as lik from '@pushrocks/lik';
+import * as smartpromise from '@pushrocks/smartpromise';
+import * as smartdelay from '@pushrocks/smartdelay';
+import * as smartrx from '@pushrocks/smartrx';
+import * as smarttime from '@pushrocks/smarttime';
+
+export { smartlog, lik, smartpromise, smartdelay, smartrx, smarttime };
--- a/tslint.json
+++ b/tslint.json
@ -0,0 +1,17 @@
+{
+  "extends": ["tslint:latest", "tslint-config-prettier"],
+  "rules": {
+    "semicolon": [true, "always"],
+    "no-console": false,
+    "ordered-imports": false,
+    "object-literal-sort-keys": false,
+    "member-ordering": {
+      "options":{
+        "order": [
+          "static-method"
+        ]
+      }
+    }
+  },
+  "defaultSeverity": "warning"
+}
Author	SHA1	Message	Date
Philipp Kunz	e9e4a60fe6	2.1.15	2021-11-11 19:59:56 +01:00
Philipp Kunz	1630f6971f	fix(core): update	2021-11-11 19:59:56 +01:00
Philipp Kunz	7bfb145513	2.1.14	2021-09-26 14:45:02 +02:00
Philipp Kunz	c367f0f949	fix(core): update	2021-09-26 14:45:02 +02:00
Phil Kunz	8f9b3151d8	2.1.13	2020-09-07 23:52:23 +00:00
Phil Kunz	81e97b513a	fix(core): update	2020-09-07 23:52:22 +00:00
Phil Kunz	7da0035805	2.1.12	2020-09-07 17:35:51 +00:00
Phil Kunz	16a77e4c41	fix(core): update	2020-09-07 17:35:50 +00:00
Phil Kunz	495f63ec71	2.1.11	2020-09-04 16:09:44 +00:00
Phil Kunz	17f840d24c	fix(core): update	2020-09-04 16:09:44 +00:00
Phil Kunz	b93407e83a	2.1.10	2020-09-04 06:47:31 +00:00
Phil Kunz	003c1f2796	fix(core): update	2020-09-04 06:47:30 +00:00
Phil Kunz	7f72a88846	2.1.9	2020-09-03 20:43:38 +00:00
Phil Kunz	823d4f7d55	fix(core): update	2020-09-03 20:43:37 +00:00
Phil Kunz	7d57fcf07e	2.1.8	2020-09-02 15:26:46 +00:00
Phil Kunz	eb9ae2fa71	fix(core): update	2020-09-02 15:26:45 +00:00
Phil Kunz	5fe60c6e50	2.1.7	2020-09-02 13:46:27 +00:00
Phil Kunz	6f811b4ab5	fix(core): update	2020-09-02 13:46:26 +00:00
Phil Kunz	2cf32ac723	2.1.6	2020-09-02 13:04:53 +00:00
Phil Kunz	09936fda56	fix(core): update	2020-09-02 13:04:52 +00:00
Phil Kunz	ddc9a77fe2	2.1.5	2020-09-02 13:04:12 +00:00
Phil Kunz	575912eab7	fix(core): update	2020-09-02 13:04:12 +00:00
Phil Kunz	eee146ae8b	2.1.4	2020-07-12 10:57:15 +00:00
Phil Kunz	ea8ef61c40	fix(core): update	2020-07-12 10:57:15 +00:00
Phil Kunz	70bb5b3f5d	2.1.3	2020-07-12 02:40:45 +00:00
Phil Kunz	5fa7312171	fix(core): update	2020-07-12 02:40:45 +00:00
Phil Kunz	cb85deeb3d	2.1.2	2020-07-12 00:48:51 +00:00
Phil Kunz	fdfb780c33	fix(core): update	2020-07-12 00:48:51 +00:00
Phil Kunz	f21b53b81d	2.1.1	2019-11-28 14:42:29 +00:00
Phil Kunz	0bf3b2ea8b	fix(core): update	2019-11-28 14:42:28 +00:00
Phil Kunz	0e81b8bd94	2.1.0	2019-11-28 11:33:26 +00:00
Phil Kunz	138aefc499	feat(taskrunner): now has working taskrunner	2019-11-28 11:33:26 +00:00
Phil Kunz	af5fa857cc	2.0.16	2019-11-27 23:34:45 +00:00
Phil Kunz	f275f7e2f6	fix(core): update	2019-11-27 23:34:45 +00:00
Phil Kunz	ea1f434cdd	2.0.15	2019-09-23 18:06:43 +02:00
Phil Kunz	2cc212f210	fix(core): update	2019-09-23 18:06:43 +02:00
Phil Kunz	2d2788d1ca	2.0.14	2019-09-23 16:31:07 +02:00
Phil Kunz	de1652bac9	fix(core): update	2019-09-23 16:31:06 +02:00
Phil Kunz	5310bef1be	2.0.13	2019-09-22 15:18:28 +02:00
Phil Kunz	1a5c67efc1	2.0.12	2019-09-22 15:16:27 +02:00
Phil Kunz	df21ebd581	fix(core): update	2019-09-22 15:16:27 +02:00
Phil Kunz	3f749dfdd2	2.0.11	2019-09-18 19:15:56 +02:00
Phil Kunz	2a39543a75	fix(core): update	2019-09-18 19:15:56 +02:00
Phil Kunz	68f7d26d3b	2.0.10	2019-09-08 22:45:37 +02:00
Phil Kunz	6373a74fb3	fix(core): update	2019-09-08 22:45:36 +02:00
Phil Kunz	be3d2d41d6	2.0.9	2019-09-06 16:32:36 +02:00
Phil Kunz	2affa189a7	fix(core): update	2019-09-06 16:32:36 +02:00
Phil Kunz	8c4c2a552c	2.0.8	2019-09-05 11:35:26 +02:00
Phil Kunz	eff9c6e6c9	fix(core): update	2019-09-05 11:35:26 +02:00
Phil Kunz	4c7a373d98	2.0.7	2019-01-15 00:20:05 +01:00
Phil Kunz	6b93a2e7ac	fix(core): update	2019-01-15 00:20:05 +01:00
Phil Kunz	9c6487c779	2.0.6	2019-01-15 00:17:45 +01:00
Phil Kunz	e3f37f5027	fix(core): update	2019-01-15 00:17:44 +01:00
Phil Kunz	1152bb1138	2.0.5	2018-08-12 20:55:07 +02:00
Phil Kunz	9df7787450	2.0.4	2018-08-11 00:01:19 +02:00
Phil Kunz	3e81fdacad	fix(CI): now building properly	2018-08-11 00:01:19 +02:00
Phil Kunz	f74da6ff0b	2.0.3	2018-08-05 23:10:01 +02:00
Phil Kunz	e9d976ad1e	fix(ci): update testing framework to the new tstest	2018-08-05 23:10:00 +02:00
Phil Kunz	f6d314695a	2.0.2	2018-08-04 18:03:23 +02:00
Phil Kunz	d35b34f4aa	fix(package.json): update private param	2018-08-04 18:03:22 +02:00
Phil Kunz	9fec5ce62e	2.0.1	2018-08-04 18:02:41 +02:00
Phil Kunz	7577479368	fix(docs): update docs	2018-08-04 18:02:41 +02:00
Phil Kunz	dbcd5bbfc8	2.0.0	2018-08-04 18:00:22 +02:00
Phil Kunz	d91b6c8360	BREAKING CHANGE(scope): switch to pushrocks scope	2018-08-04 18:00:21 +02:00
Phil Kunz	b9af186190	update	2018-08-04 17:59:01 +02:00
Phil Kunz	bdb7064394	update	2018-08-04 17:58:46 +02:00
Phil Kunz	f60deddadd	fix(tests): now using tstest	2018-08-04 17:53:22 +02:00
Phil Kunz	df18aba4b5	1.0.22	2017-07-12 16:45:21 +02:00
Phil Kunz	a3699f2869	introduce TaskOnce	2017-07-12 16:45:18 +02:00
Phil Kunz	017c0789ca	1.0.21	2017-07-10 14:29:02 +02:00
Phil Kunz	6e6d056617	update docs	2017-07-10 14:28:58 +02:00
Phil Kunz	3f7f38ee17	1.0.20	2017-07-10 12:49:04 +02:00
Phil Kunz	5bfc72a602	add docs	2017-07-10 12:48:57 +02:00
Phil Kunz	ca8882962e	1.0.19	2017-07-10 12:45:36 +02:00
Phil Kunz	df6bf2c681	updated dependencies	2017-07-10 12:45:33 +02:00
Phil Kunz	310a683e14	1.0.18	2017-07-10 12:42:11 +02:00
Phil Kunz	3f275ebc08	implemented execDelay	2017-07-10 12:42:06 +02:00
Phil Kunz	01d469960e	1.0.17	2017-06-18 13:25:12 +02:00
Phil Kunz	2ed701040a	now has working TaskManager	2017-06-18 13:25:09 +02:00
Phil Kunz	ca3bb38205	update test texts	2017-06-17 17:29:26 +02:00
Phil Kunz	891d727fd4	1.0.16	2017-06-17 16:56:37 +02:00
Phil Kunz	e1424ea0fb	implement TaskManager	2017-06-17 16:56:33 +02:00
Phil Kunz	cf1b31d635	1.0.15	2017-06-09 23:34:40 +02:00
Phil Kunz	d5570311ee	update ci	2017-06-09 23:34:37 +02:00
Phil Kunz	44b3ba1313	1.0.14	2017-06-09 23:33:45 +02:00
Phil Kunz	4721d8c9e6	clean up code	2017-06-09 23:33:41 +02:00
Phil Kunz	c7336eedfb	1.0.13	2017-06-09 23:26:25 +02:00
Phil Kunz	5477911b5e	update to latest standards	2017-06-09 23:26:23 +02:00
Phil Kunz	2f8d3f7625	1.0.12	2017-02-15 22:52:34 +01:00
Phil Kunz	b00d31b41a	update dependencies	2017-02-15 22:52:29 +01:00
Phil Kunz	4031692f6f	1.0.11	2017-01-20 21:36:21 +01:00
Phil Kunz	174beae65f	fix test	2017-01-20 21:36:18 +01:00
Phil Kunz	c1144d3405	add taskmanager class	2017-01-20 20:48:07 +01:00
Phil Kunz	065d92e573	1.0.10	2017-01-20 18:54:28 +01:00
Phil Kunz	46878819df	add better readme	2017-01-20 18:54:23 +01:00
Phil Kunz	aa8df29bbb	1.0.9	2017-01-20 18:50:43 +01:00
Phil Kunz	f5cb0843fc	smartq now working	2017-01-20 18:50:37 +01:00
Phil Kunz	1d52d098fb	Merge branch 'master' into 'master' update from q to smartq See merge request !1	2017-01-20 08:33:32 +00:00
Phil Kunz	eb7eb14415	update from q to smartq	2017-01-19 17:26:35 +01:00
PhilKunz	670bf5b124	1.0.8	2016-09-02 18:11:49 +02:00
PhilKunz	fab863c66c	update dependencies	2016-09-02 18:11:33 +02:00
PhilKunz	402e2b982f	1.0.7	2016-08-03 14:51:47 +02:00
PhilKunz	1d0a85e6ca	now returning correct Promise types	2016-08-03 14:51:43 +02:00
PhilKunz	7ded7b036e	1.0.6	2016-08-03 12:14:29 +02:00
PhilKunz	03020eacbc	update type versions	2016-08-03 12:14:21 +02:00
PhilKunz	dc95885646	1.0.5	2016-08-03 11:28:21 +02:00
PhilKunz	11cdaad226	add error catching	2016-08-03 11:28:13 +02:00
PhilKunz	a1ad463140	1.0.4	2016-08-02 11:10:08 +02:00
PhilKunz	76c57451b3	values now flow correctly between tasks	2016-08-02 11:09:42 +02:00
PhilKunz	5dca9a9460	1.0.3	2016-08-01 16:10:06 +02:00
PhilKunz	d30fb551f9	now running correctly in buffered mode	2016-08-01 16:10:00 +02:00
PhilKunz	7a60f30f0b	1.0.2	2016-08-01 13:35:38 +02:00
PhilKunz	9e175245ed	update README	2016-08-01 13:35:33 +02:00