jasmine/spec/core/QueueRunnerSpec.js

describe("QueueRunner", function() {

  it("runs all the functions it's passed", function() {
    var calls = [],
      fn1 = jasmine.createSpy('fn1'),
      fn2 = jasmine.createSpy('fn2'),
      queueRunner = new j$.QueueRunner({
        fns: [fn1, fn2]
      });
    fn1.and.callFake(function() {
      calls.push('fn1');
    });
    fn2.and.callFake(function() {
      calls.push('fn2');
    });

    queueRunner.execute();

    expect(calls).toEqual(['fn1', 'fn2']);
  });

  it("calls each function with a consistent 'this'-- an empty object", function() {
    var fn1 = jasmine.createSpy('fn1'),
        fn2 = jasmine.createSpy('fn2'),
        fn3 = function(done) { asyncContext = this; done(); },
        queueRunner = new j$.QueueRunner({
          fns: [fn1, fn2, fn3]
        }),
        asyncContext;

    queueRunner.execute();

    var context = fn1.calls.first().object;
    expect(context).toEqual({});
    expect(fn2.calls.first().object).toBe(context);
    expect(asyncContext).toBe(context);
  });

  it("supports asynchronous functions, only advancing to next function after a done() callback", function() {
    //TODO: it would be nice if spy arity could match the fake, so we could do something like:
    //createSpy('asyncfn').and.callFake(function(done) {});

    var onComplete = jasmine.createSpy('onComplete'),
      beforeCallback = jasmine.createSpy('beforeCallback'),
      fnCallback = jasmine.createSpy('fnCallback'),
      afterCallback = jasmine.createSpy('afterCallback'),
      fn1 = function(done) {
        beforeCallback();
        setTimeout(function() {
          done()
        }, 100);
      },
      fn2 = function(done) {
        fnCallback();
        setTimeout(function() {
          done()
        }, 100);
      },
      fn3 = function(done) {
        afterCallback();
        setTimeout(function() {
          done()
        }, 100);
      },
      queueRunner = new j$.QueueRunner({
        fns: [fn1, fn2, fn3],
        onComplete: onComplete
      });

    clock.install();

    queueRunner.execute();

    expect(beforeCallback).toHaveBeenCalled();
    expect(fnCallback).not.toHaveBeenCalled();
    expect(afterCallback).not.toHaveBeenCalled();
    expect(onComplete).not.toHaveBeenCalled();

    clock.tick(100);

    expect(fnCallback).toHaveBeenCalled();
    expect(afterCallback).not.toHaveBeenCalled();
    expect(onComplete).not.toHaveBeenCalled();

    clock.tick(100);

    expect(afterCallback).toHaveBeenCalled();
    expect(onComplete).not.toHaveBeenCalled();

    clock.tick(100);

    expect(onComplete).toHaveBeenCalled();
  });

  it("calls an exception handler when an exception is thrown in a fn", function() {
    var fn = function() {
        throw new Error('fake error');
      },
      exceptionCallback = jasmine.createSpy('exception callback'),
      queueRunner = new j$.QueueRunner({
        fns: [fn],
        onException: exceptionCallback
      });

    queueRunner.execute();

    expect(exceptionCallback).toHaveBeenCalledWith(jasmine.any(Error));
  });

  it("rethrows an exception if told to", function() {
    var fn = function() {
        throw new Error('fake error');
      },
      queueRunner = new j$.QueueRunner({
        fns: [fn],
        catchException: function(e) { return false; }
      });

    expect(function() { queueRunner.execute(); }).toThrow();
  });

  it("continues running the functions even after an exception is thrown in an async spec", function() {
    var fn = function(done) { throw new Error("error"); },
        nextFn = jasmine.createSpy("nextFunction");

    queueRunner = new j$.QueueRunner({
      fns: [fn, nextFn]
    });

    queueRunner.execute();
    expect(nextFn).toHaveBeenCalled();
  });

  it("calls a provided complete callback when done", function() {
    var fn = jasmine.createSpy('fn'),
      completeCallback = jasmine.createSpy('completeCallback'),
      queueRunner = new j$.QueueRunner({
        fns: [fn],
        onComplete: completeCallback
      });

    queueRunner.execute();

    expect(completeCallback).toHaveBeenCalled();
  });

  it("calls a provided stack clearing function when done", function() {
    var asyncFn = function(done) { done() },
        afterFn = jasmine.createSpy('afterFn'),
        completeCallback = jasmine.createSpy('completeCallback'),
        clearStack = jasmine.createSpy('clearStack'),
        queueRunner = new j$.QueueRunner({
          fns: [asyncFn, afterFn],
          clearStack: clearStack,
          onComplete: completeCallback
        });

    clearStack.and.callFake(function(fn) { fn(); });

    queueRunner.execute();
    expect(afterFn).toHaveBeenCalled();
    expect(clearStack).toHaveBeenCalledWith(completeCallback);
  });
});