Method constructor

packages/hydrooj/src/model/task.ts:41–45

(public filter: any, public func: (t: Task) => Promise<void>, public destroyOnError = true, private concurrency = 1)

    notify: (res?: any) => void;

    constructor(public filter: any, public func: (t: Task) => Promise<void>, public destroyOnError = true, private concurrency = 1) {
        this.consuming = true;
        this.consume();
        bus.on('app/exit', this.destroy);
    }

    async consume() {
        while (this.consuming) {