diff options
| author | Danijel Andjelkovic <adanijel99@gmail.com> | 2022-03-01 20:21:29 +0000 | 
|---|---|---|
| committer | Danijel Andjelkovic <adanijel99@gmail.com> | 2022-03-01 20:21:29 +0000 | 
| commit | 61cb1570a3410c85a4489b97c172e3a50715f36c (patch) | |
| tree | 8fe4a5b77ea54bba80abc817ce2c9ef0e79e7e66 /sandbox/testAppNevena/Front/node_modules/rxjs/internal/scheduler/AsyncScheduler.js | |
| parent | 21a53d349788c99d2007cba91a923db982353b31 (diff) | |
| parent | a9ee9e0a500a4a15bd0b5dcaf041f827228ed309 (diff) | |
Merge branch 'researchML' into 'dev'
Research ml
See merge request igrannonica/neuronstellar!6
Diffstat (limited to 'sandbox/testAppNevena/Front/node_modules/rxjs/internal/scheduler/AsyncScheduler.js')
| -rw-r--r-- | sandbox/testAppNevena/Front/node_modules/rxjs/internal/scheduler/AsyncScheduler.js | 67 | 
1 files changed, 67 insertions, 0 deletions
| diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/scheduler/AsyncScheduler.js b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/scheduler/AsyncScheduler.js new file mode 100644 index 00000000..10e9a12d --- /dev/null +++ b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/scheduler/AsyncScheduler.js @@ -0,0 +1,67 @@ +"use strict"; +var __extends = (this && this.__extends) || (function () { +    var extendStatics = function (d, b) { +        extendStatics = Object.setPrototypeOf || +            ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) || +            function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; }; +        return extendStatics(d, b); +    } +    return function (d, b) { +        extendStatics(d, b); +        function __() { this.constructor = d; } +        d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __()); +    }; +})(); +Object.defineProperty(exports, "__esModule", { value: true }); +var Scheduler_1 = require("../Scheduler"); +var AsyncScheduler = (function (_super) { +    __extends(AsyncScheduler, _super); +    function AsyncScheduler(SchedulerAction, now) { +        if (now === void 0) { now = Scheduler_1.Scheduler.now; } +        var _this = _super.call(this, SchedulerAction, function () { +            if (AsyncScheduler.delegate && AsyncScheduler.delegate !== _this) { +                return AsyncScheduler.delegate.now(); +            } +            else { +                return now(); +            } +        }) || this; +        _this.actions = []; +        _this.active = false; +        _this.scheduled = undefined; +        return _this; +    } +    AsyncScheduler.prototype.schedule = function (work, delay, state) { +        if (delay === void 0) { delay = 0; } +        if (AsyncScheduler.delegate && AsyncScheduler.delegate !== this) { +            return AsyncScheduler.delegate.schedule(work, delay, state); +        } +        else { +            return _super.prototype.schedule.call(this, work, delay, state); +        } +    }; +    AsyncScheduler.prototype.flush = function (action) { +        var actions = this.actions; +        if (this.active) { +            actions.push(action); +            return; +        } +        var error; +        this.active = true; +        do { +            if (error = action.execute(action.state, action.delay)) { +                break; +            } +        } while (action = actions.shift()); +        this.active = false; +        if (error) { +            while (action = actions.shift()) { +                action.unsubscribe(); +            } +            throw error; +        } +    }; +    return AsyncScheduler; +}(Scheduler_1.Scheduler)); +exports.AsyncScheduler = AsyncScheduler; +//# sourceMappingURL=AsyncScheduler.js.map
\ No newline at end of file | 
