rl-async-testing/lib/fakeAsync.js

"use strict";
var rxjs_1 = require('rxjs');
var requestQueue = [];
var timeElapsed = 0;
var testing_1 = require('@angular/core/testing');
exports.flushMicrotasks = testing_1.flushMicrotasks;
/**
 * Wraps angular fakeAsync with the ability to track pending requests
 *
 * When a request is initiated using mockAsync, the request is pushed to the requestQueue
 * If there are any pending requests at the end of the function, an exception will be thrown.
 *
 * Also overrides 'now' on the default rxjs scheduler to return a value based on how much time has elapsed via 'tick'
 *
 * @param fn
 * @returns {Function} The function wrapped to be executed in the fakeAsync zone
 */
function rlFakeAsync(fn) {
    return testing_1.fakeAsync(function () {
        var args = [];
        for (var _i = 0; _i < arguments.length; _i++) {
            args[_i - 0] = arguments[_i];
        }
        var originalNow = rxjs_1.Scheduler.async.now;
        timeElapsed = 0;
        rxjs_1.Scheduler.async.now = function () { return timeElapsed; };
        requestQueue = [];
        var res = fn.apply(void 0, args);
        testing_1.flushMicrotasks();
        if (requestQueue.some(function (request) { return request.pending; })) {
            throw new Error('There are still pending requests. Please be sure to flush all of your requests');
        }
        rxjs_1.Scheduler.async.now = originalNow;
        return res;
    });
}
exports.rlFakeAsync = rlFakeAsync;
function rlQueueRequest(request) {
    requestQueue.push(request);
}
exports.rlQueueRequest = rlQueueRequest;
function rlTick(milliseconds) {
    timeElapsed += milliseconds;
    testing_1.tick(milliseconds);
}
exports.rlTick = rlTick;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiZmFrZUFzeW5jLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiZmFrZUFzeW5jLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7QUFBQSxxQkFBMEIsTUFBTSxDQUFDLENBQUE7QUFFakMsSUFBSSxZQUFZLEdBQUcsRUFBRSxDQUFDO0FBQ3RCLElBQUksV0FBVyxHQUFXLENBQUMsQ0FBQztBQUU1Qix3QkFBMEUsdUJBQXVCLENBQUMsQ0FBQTtBQUN6Rix1QkFBZTtBQUV4Qjs7Ozs7Ozs7OztHQVVHO0FBQ0gscUJBQTRCLEVBQVk7SUFDdkMsTUFBTSxDQUFDLG1CQUFXLENBQUM7UUFBVSxjQUFPO2FBQVAsV0FBTyxDQUFQLHNCQUFPLENBQVAsSUFBTztZQUFQLDZCQUFPOztRQUNuQyxJQUFNLFdBQVcsR0FBRyxnQkFBUyxDQUFDLEtBQUssQ0FBQyxHQUFHLENBQUM7UUFDeEMsV0FBVyxHQUFHLENBQUMsQ0FBQztRQUNoQixnQkFBUyxDQUFDLEtBQUssQ0FBQyxHQUFHLEdBQUcsY0FBTSxPQUFBLFdBQVcsRUFBWCxDQUFXLENBQUM7UUFDeEMsWUFBWSxHQUFHLEVBQUUsQ0FBQztRQUNsQixJQUFJLEdBQUcsR0FBRyxFQUFFLGVBQUksSUFBSSxDQUFDLENBQUM7UUFDdEIseUJBQWUsRUFBRSxDQUFDO1FBQ2xCLEVBQUUsQ0FBQyxDQUFDLFlBQVksQ0FBQyxJQUFJLENBQUMsVUFBQSxPQUFPLElBQUksT0FBQSxPQUFPLENBQUMsT0FBTyxFQUFmLENBQWUsQ0FBQyxDQUFDLENBQUMsQ0FBQztZQUNuRCxNQUFNLElBQUksS0FBSyxDQUFDLGdGQUFnRixDQUFDLENBQUM7UUFDbkcsQ0FBQztRQUNELGdCQUFTLENBQUMsS0FBSyxDQUFDLEdBQUcsR0FBRyxXQUFXLENBQUM7UUFDbEMsTUFBTSxDQUFDLEdBQUcsQ0FBQztJQUNaLENBQUMsQ0FBQyxDQUFDO0FBQ0osQ0FBQztBQWRlLG1CQUFXLGNBYzFCLENBQUE7QUFFRCx3QkFBK0IsT0FBTztJQUNyQyxZQUFZLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxDQUFDO0FBQzVCLENBQUM7QUFGZSxzQkFBYyxpQkFFN0IsQ0FBQTtBQUVELGdCQUF1QixZQUFvQjtJQUMxQyxXQUFXLElBQUksWUFBWSxDQUFDO0lBQzVCLGNBQU0sQ0FBQyxZQUFZLENBQUMsQ0FBQztBQUN0QixDQUFDO0FBSGUsY0FBTSxTQUdyQixDQUFBIn0=