/// <reference path="../reactiveassert.js" />

/// <reference path="../rx.js" />

/// <reference path="../rx.testing.js" />

(function(window) {

// Check if browser vs node

var root = window.Rx;

QUnit.module('ObservableSingleTest');

var Observable = root.Observable,

TestScheduler = root.TestScheduler,

onNext = root.ReactiveTest.onNext,

onError = root.ReactiveTest.onError,

onCompleted = root.ReactiveTest.onCompleted,

subscribe = root.ReactiveTest.subscribe;

test('Materialize_Never', function () {

var results, scheduler;

scheduler = new TestScheduler();

results = scheduler.startWithCreate(function () {

return Rx.Observable.never().materialize();

});

results.messages.assertEqual();

});

test('Materialize_Empty', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.materialize();

}).messages;

equal(2, results.length);

ok(results[0].value.kind === 'N' && results[0].value.value.kind === 'C' && results[0].time === 250);

ok(results[1].value.kind === 'C' && results[1].time === 250);

});

test('Materialize_Return', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.materialize();

}).messages;

equal(3, results.length);

ok(results[0].value.kind === 'N' && results[0].value.value.kind === 'N' && results[0].value.value.value === 2 && results[0].time === 210);

ok(results[1].value.kind === 'N' && results[1].value.value.kind === 'C' && results[1].time === 250);

ok(results[2].value.kind === 'C' && results[1].time === 250);

});

test('Materialize_Throw', function () {

var ex, results, scheduler, xs;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onError(250, ex));

results = scheduler.startWithCreate(function () {

return xs.materialize();

}).messages;

equal(2, results.length);

ok(results[0].value.kind === 'N' && results[0].value.value.kind === 'E' && results[0].value.value.exception === ex);

ok(results[1].value.kind === 'C');

});

test('Materialize_Dematerialize_Never', function () {

var results, scheduler;

scheduler = new TestScheduler();

results = scheduler.startWithCreate(function () {

return Rx.Observable.never().materialize().dematerialize();

});

results.messages.assertEqual();

});

test('Materialize_Dematerialize_Empty', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.materialize().dematerialize();

}).messages;

equal(1, results.length);

ok(results[0].value.kind === 'C' && results[0].time === 250);

});

test('Materialize_Dematerialize_Return', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.materialize().dematerialize();

}).messages;

equal(2, results.length);

ok(results[0].value.kind === 'N' && results[0].value.value === 2 && results[0].time === 210);

ok(results[1].value.kind === 'C');

});

test('Materialize_Dematerialize_Throw', function () {

var ex, results, scheduler, xs;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onError(250, ex));

results = scheduler.startWithCreate(function () {

return xs.materialize().dematerialize();

}).messages;

equal(1, results.length);

ok(results[0].value.kind === 'E' && results[0].value.exception === ex && results[0].time === 250);

});

test('StartWith', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(220, 2), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.startWith(1);

}).messages;

equal(3, results.length);

ok(results[0].value.kind === 'N' && results[0].value.value === 1 && results[0].time === 200);

ok(results[1].value.kind === 'N' && results[1].value.value === 2 && results[1].time === 220);

ok(results[2].value.kind === 'C');

});

var sequenceEqual;

sequenceEqual = function (arr1, arr2) {

var i;

if (arr1.length !== arr2.length) {

return false;

}

for (i = 0; i < arr1.length; i++) {

if (arr1[i] !== arr2[i]) {

return false;

}

}

return true;

};

test('Buffer_Count_PartialWindow', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.bufferWithCount(5);

}).messages;

equal(2, results.length);

ok(sequenceEqual(results[0].value.value, [2, 3, 4, 5]) && results[0].time === 250);

ok(results[1].value.kind === 'C' && results[1].time === 250);

});

test('Buffer_Count_FullWindows', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.bufferWithCount(2);

}).messages;

equal(3, results.length);

ok(sequenceEqual(results[0].value.value, [2, 3]) && results[0].time === 220);

ok(sequenceEqual(results[1].value.value, [4, 5]) && results[1].time === 240);

ok(results[2].value.kind === 'C' && results[2].time === 250);

});

test('Buffer_Count_FullAndPartialWindows', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.bufferWithCount(3);

}).messages;

equal(3, results.length);

ok(sequenceEqual(results[0].value.value, [2, 3, 4]) && results[0].time === 230);

ok(sequenceEqual(results[1].value.value, [5]) && results[1].time === 250);

ok(results[2].value.kind === 'C' && results[2].time === 250);

});

test('Buffer_Count_Error', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onError(250, 'ex'));

results = scheduler.startWithCreate(function () {

return xs.bufferWithCount(5);

}).messages;

equal(1, results.length);

ok(results[0].value.kind === 'E' && results[0].time === 250);

});

test('Buffer_Count_Skip_Less', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.bufferWithCount(3, 1);

}).messages;

equal(5, results.length);

ok(sequenceEqual(results[0].value.value, [2, 3, 4]) && results[0].time === 230);

ok(sequenceEqual(results[1].value.value, [3, 4, 5]) && results[1].time === 240);

ok(sequenceEqual(results[2].value.value, [4, 5]) && results[2].time === 250);

ok(sequenceEqual(results[3].value.value, [5]) && results[3].time === 250);

ok(results[4].value.kind === 'C' && results[4].time === 250);

});

test('Buffer_Count_Skip_More', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.bufferWithCount(2, 3);

}).messages;

equal(3, results.length);

ok(sequenceEqual(results[0].value.value, [2, 3]) && results[0].time === 220);

ok(sequenceEqual(results[1].value.value, [5]) && results[1].time === 250);

ok(results[2].value.kind === 'C' && results[2].time === 250);

});

test('AsObservable_Hides', function () {

var someObservable;

someObservable = Rx.Observable.empty();

ok(someObservable.asObservable() !== someObservable);

});

test('AsObservable_Never', function () {

var results, scheduler;

scheduler = new TestScheduler();

results = scheduler.startWithCreate(function () {

return Rx.Observable.never().asObservable();

});

results.messages.assertEqual();

});

test('AsObservable_Empty', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.asObservable();

}).messages;

equal(1, results.length);

ok(results[0].value.kind === 'C' && results[0].time === 250);

});

test('AsObservable_Throw', function () {

var ex, results, scheduler, xs;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onError(250, ex));

results = scheduler.startWithCreate(function () {

return xs.asObservable();

}).messages;

equal(1, results.length);

ok(results[0].value.kind === 'E' && results[0].value.exception === ex && results[0].time === 250);

});

test('AsObservable_Return', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(220, 2), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.asObservable();

}).messages;

equal(2, results.length);

ok(results[0].value.kind === 'N' && results[0].value.value === 2 && results[0].time === 220);

ok(results[1].value.kind === 'C' && results[1].time === 250);

});

test('AsObservable_IsNotEager', function () {

var scheduler, subscribed, xs;

scheduler = new TestScheduler();

subscribed = false;

xs = Rx.Observable.create(function (obs) {

var disp;

subscribed = true;

disp = scheduler.createHotObservable(onNext(150, 1), onNext(220, 2), onCompleted(250)).subscribe(obs);

return function () {

return disp.dispose();

};

});

xs.asObservable();

ok(!subscribed);

scheduler.startWithCreate(function () {

return xs.asObservable();

});

ok(subscribed);

});

test('Scan_Seed_Never', function () {

var results, scheduler, seed;

scheduler = new TestScheduler();

seed = 42;

results = scheduler.startWithCreate(function () {

return Rx.Observable.never().scan(seed, function (acc, x) {

return acc + x;

});

});

results.messages.assertEqual();

});

test('Scan_Seed_Empty', function () {

var results, scheduler, seed, xs;

scheduler = new TestScheduler();

seed = 42;

xs = scheduler.createHotObservable(onNext(150, 1), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.scan(seed, function (acc, x) {

return acc + x;

});

}).messages;

equal(1, results.length);

ok(results[0].value.kind === 'C' && results[0].time === 250);

});

test('Scan_Seed_Return', function () {

var results, scheduler, seed, xs;

scheduler = new TestScheduler();

seed = 42;

xs = scheduler.createHotObservable(onNext(150, 1), onNext(220, 2), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.scan(seed, function (acc, x) {

return acc + x;

});

}).messages;

equal(2, results.length);

ok(results[0].value.kind === 'N' && results[0].value.value === seed + 2 && results[0].time === 220);

ok(results[1].value.kind === 'C' && results[1].time === 250);

});

test('Scan_Seed_Throw', function () {

var ex, results, scheduler, seed, xs;

ex = 'ex';

scheduler = new TestScheduler();

seed = 42;

xs = scheduler.createHotObservable(onNext(150, 1), onError(250, ex));

results = scheduler.startWithCreate(function () {

return xs.scan(seed, function (acc, x) {

return acc + x;

});

}).messages;

equal(1, results.length);

ok(results[0].value.kind === 'E' && results[0].value.exception === ex && results[0].time === 250);

});

test('Scan_Seed_SomeData', function () {

var results, scheduler, seed, xs;

scheduler = new TestScheduler();

seed = 1;

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.scan(seed, function (acc, x) {

return acc + x;

});

}).messages;

equal(5, results.length);

ok(results[0].value.kind === 'N' && results[0].value.value === seed + 2 && results[0].time === 210);

ok(results[1].value.kind === 'N' && results[1].value.value === seed + 2 + 3 && results[1].time === 220);

ok(results[2].value.kind === 'N' && results[2].value.value === seed + 2 + 3 + 4 && results[2].time === 230);

ok(results[3].value.kind === 'N' && results[3].value.value === seed + 2 + 3 + 4 + 5 && results[3].time === 240);

ok(results[4].value.kind === 'C' && results[4].time === 250);

});

test('Scan_NoSeed_Never', function () {

var results, scheduler;

scheduler = new TestScheduler();

results = scheduler.startWithCreate(function () {

return Rx.Observable.never().scan(function (acc, x) {

return acc + x;

});

});

results.messages.assertEqual();

});

test('Scan_NoSeed_Empty', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.scan(function (acc, x) {

return acc + x;

});

}).messages;

equal(1, results.length);

ok(results[0].value.kind === 'C' && results[0].time === 250);

});

test('Scan_NoSeed_Return', function () {

var results, scheduler, xs, _undefined;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(220, 2), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.scan(function (acc, x) {

if (acc === _undefined) {

acc = 0;

}

return acc + x;

});

}).messages;

equal(2, results.length);

ok(results[0].value.kind === 'N' && results[0].time === 220 && results[0].value.value === 2);

ok(results[1].value.kind === 'C' && results[1].time === 250);

});

test('Scan_NoSeed_Throw', function () {

var ex, results, scheduler, xs, _undefined;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onError(250, ex));

results = scheduler.startWithCreate(function () {

return xs.scan(function (acc, x) {

if (acc === _undefined) {

acc = 0;

}

return acc + x;

});

}).messages;

equal(1, results.length);

ok(results[0].value.kind === 'E' && results[0].time === 250 && results[0].value.exception === ex);

});

test('Scan_NoSeed_SomeData', function () {

var results, scheduler, xs, _undefined;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.scan(function (acc, x) {

if (acc === _undefined) {

acc = 0;

}

return acc + x;

});

}).messages;

equal(5, results.length);

ok(results[0].value.kind === 'N' && results[0].time === 210 && results[0].value.value === 2);

ok(results[1].value.kind === 'N' && results[1].time === 220 && results[1].value.value === 2 + 3);

ok(results[2].value.kind === 'N' && results[2].time === 230 && results[2].value.value === 2 + 3 + 4);

ok(results[3].value.kind === 'N' && results[3].time === 240 && results[3].value.value === 2 + 3 + 4 + 5);

ok(results[4].value.kind === 'C' && results[4].time === 250);

});

test('DistinctUntilChanged_Never', function () {

var results, scheduler;

scheduler = new TestScheduler();

results = scheduler.startWithCreate(function () {

return Rx.Observable.never().distinctUntilChanged();

});

results.messages.assertEqual();

});

test('DistinctUntilChanged_Empty', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.distinctUntilChanged();

}).messages;

equal(1, results.length);

ok(results[0].value.kind === 'C' && results[0].time === 250);

});

test('DistinctUntilChanged_Return', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(220, 2), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.distinctUntilChanged();

}).messages;

equal(2, results.length);

ok(results[0].value.kind === 'N' && results[0].time === 220 && results[0].value.value === 2);

ok(results[1].value.kind === 'C' && results[1].time === 250);

});

test('DistinctUntilChanged_Throw', function () {

var ex, results, scheduler, xs;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onError(250, ex));

results = scheduler.startWithCreate(function () {

return xs.distinctUntilChanged();

}).messages;

equal(1, results.length);

ok(results[0].value.kind === 'E' && results[0].time === 250 && results[0].value.exception === ex);

});

test('DistinctUntilChanged_AllChanges', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.distinctUntilChanged();

}).messages;

equal(5, results.length);

ok(results[0].value.kind === 'N' && results[0].time === 210 && results[0].value.value === 2);

ok(results[1].value.kind === 'N' && results[1].time === 220 && results[1].value.value === 3);

ok(results[2].value.kind === 'N' && results[2].time === 230 && results[2].value.value === 4);

ok(results[3].value.kind === 'N' && results[3].time === 240 && results[3].value.value === 5);

ok(results[4].value.kind === 'C' && results[4].time === 250);

});

test('DistinctUntilChanged_AllSame', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 2), onNext(230, 2), onNext(240, 2), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.distinctUntilChanged();

}).messages;

equal(2, results.length);

ok(results[0].value.kind === 'N' && results[0].time === 210 && results[0].value.value === 2);

ok(results[1].value.kind === 'C' && results[1].time === 250);

});

test('DistinctUntilChanged_SomeChanges', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(215, 3), onNext(220, 3), onNext(225, 2), onNext(230, 2), onNext(230, 1), onNext(240, 2), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.distinctUntilChanged();

}).messages;

equal(6, results.length);

ok(results[0].value.kind === 'N' && results[0].time === 210 && results[0].value.value === 2);

ok(results[1].value.kind === 'N' && results[1].time === 215 && results[1].value.value === 3);

ok(results[2].value.kind === 'N' && results[2].time === 225 && results[2].value.value === 2);

ok(results[3].value.kind === 'N' && results[3].time === 230 && results[3].value.value === 1);

ok(results[4].value.kind === 'N' && results[4].time === 240 && results[4].value.value === 2);

ok(results[5].value.kind === 'C' && results[5].time === 250);

});

test('DistinctUntilChanged_Comparer_AllEqual', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.distinctUntilChanged(void 0, function (x, y) {

return true;

});

}).messages;

equal(2, results.length);

ok(results[0].value.kind === 'N' && results[0].time === 210 && results[0].value.value === 2);

ok(results[1].value.kind === 'C' && results[1].time === 250);

});

test('DistinctUntilChanged_Comparer_AllDifferent', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 2), onNext(230, 2), onNext(240, 2), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.distinctUntilChanged(void 0, function (x, y) {

return false;

});

}).messages;

equal(5, results.length);

ok(results[0].value.kind === 'N' && results[0].time === 210 && results[0].value.value === 2);

ok(results[1].value.kind === 'N' && results[1].time === 220 && results[1].value.value === 2);

ok(results[2].value.kind === 'N' && results[2].time === 230 && results[2].value.value === 2);

ok(results[3].value.kind === 'N' && results[3].time === 240 && results[3].value.value === 2);

ok(results[4].value.kind === 'C' && results[4].time === 250);

});

test('DistinctUntilChanged_KeySelector_Div2', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 4), onNext(230, 3), onNext(240, 5), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.distinctUntilChanged(function (x) {

return x % 2;

});

}).messages;

equal(3, results.length);

ok(results[0].value.kind === 'N' && results[0].time === 210 && results[0].value.value === 2);

ok(results[1].value.kind === 'N' && results[1].time === 230 && results[1].value.value === 3);

ok(results[2].value.kind === 'C' && results[2].time === 250);

});

test('DistinctUntilChanged_KeySelectorThrows', function () {

var ex, results, scheduler, xs;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.distinctUntilChanged(function (x) {

throw ex;

});

});

results.messages.assertEqual(onError(210, ex));

});

test('DistinctUntilChanged_ComparerThrows', function () {

var ex, results, scheduler, xs;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.distinctUntilChanged(void 0, function (x, y) {

throw ex;

});

});

results.messages.assertEqual(onNext(210, 2), onError(220, ex));

});

test('Finally_OnlyCalledOnce_Empty', function () {

var d, invokeCount, someObservable;

invokeCount = 0;

someObservable = Rx.Observable.empty().finallyAction(function () {

return invokeCount++;

});

d = someObservable.subscribe();

d.dispose();

d.dispose();

equal(1, invokeCount);

});

test('Finally_Empty', function () {

var invoked, results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onCompleted(250));

invoked = false;

results = scheduler.startWithCreate(function () {

return xs.finallyAction(function () {

return invoked = true;

});

}).messages;

equal(1, results.length);

ok(results[0].value.kind === 'C' && results[0].time === 250);

ok(invoked);

});

test('Finally_Return', function () {

var invoked, results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onCompleted(250));

invoked = false;

results = scheduler.startWithCreate(function () {

return xs.finallyAction(function () {

return invoked = true;

});

}).messages;

equal(2, results.length);

ok(results[0].value.kind === 'N' && results[0].time === 210 && results[0].value.value === 2);

ok(results[1].value.kind === 'C' && results[1].time === 250);

ok(invoked);

});

test('Finally_Throw', function () {

var ex, invoked, results, scheduler, xs;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onError(250, ex));

invoked = false;

results = scheduler.startWithCreate(function () {

return xs.finallyAction(function () {

return invoked = true;

});

}).messages;

equal(1, results.length);

ok(results[0].value.kind === 'E' && results[0].time === 250 && results[0].value.exception === ex);

ok(invoked);

});

test('Do_ShouldSeeAllValues', function () {

var i, scheduler, sum, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onCompleted(250));

i = 0;

sum = 2 + 3 + 4 + 5;

scheduler.startWithCreate(function () {

return xs.doAction(function (x) {

i++;

return sum -= x;

});

});

equal(4, i);

equal(0, sum);

});

test('Do_PlainAction', function () {

var i, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onCompleted(250));

i = 0;

scheduler.startWithCreate(function () {

return xs.doAction(function (x) {

return i++;

});

});

equal(4, i);

});

test('Do_NextCompleted', function () {

var completed, i, scheduler, sum, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onCompleted(250));

i = 0;

sum = 2 + 3 + 4 + 5;

completed = false;

scheduler.startWithCreate(function () {

return xs.doAction(function (x) {

i++;

sum -= x;

}, undefined, function () {

completed = true;

});

});

equal(4, i);

equal(0, sum);

ok(completed);

});

test('Do_NextCompleted_Never', function () {

var completed, i, scheduler;

scheduler = new TestScheduler();

i = 0;

completed = false;

scheduler.startWithCreate(function () {

return Rx.Observable.never().doAction(function (x) {

i++;

}, undefined, function () {

completed = true;

});

});

equal(0, i);

ok(!completed);

});

test('Do_NextError', function () {

var ex, i, sawError, scheduler, sum, xs;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onError(250, ex));

i = 0;

sum = 2 + 3 + 4 + 5;

sawError = false;

scheduler.startWithCreate(function () {

return xs.doAction(function (x) {

i++;

sum -= x;

}, function (e) {

sawError = e === ex;

});

});

equal(4, i);

equal(0, sum);

ok(sawError);

});

test('Do_NextErrorNot', function () {

var i, sawError, scheduler, sum, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onCompleted(250));

i = 0;

sum = 2 + 3 + 4 + 5;

sawError = false;

scheduler.startWithCreate(function () {

return xs.doAction(function (x) {

i++;

sum -= x;

}, function (e) {

sawError = true;

});

});

equal(4, i);

equal(0, sum);

ok(!sawError);

});

test('Do_NextErrorCompleted', function () {

var hasCompleted, i, sawError, scheduler, sum, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onCompleted(250));

i = 0;

sum = 2 + 3 + 4 + 5;

sawError = false;

hasCompleted = false;

scheduler.startWithCreate(function () {

return xs.doAction(function (x) {

i++;

sum -= x;

}, function (e) {

sawError = true;

}, function () {

hasCompleted = true;

});

});

equal(4, i);

equal(0, sum);

ok(!sawError);

ok(hasCompleted);

});

test('Do_NextErrorCompletedError', function () {

var ex, hasCompleted, i, sawError, scheduler, sum, xs;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onError(250, ex));

i = 0;

sum = 2 + 3 + 4 + 5;

sawError = false;

hasCompleted = false;

scheduler.startWithCreate(function () {

return xs.doAction(function (x) {

i++;

sum -= x;

}, function (e) {

sawError = ex === e;

}, function () {

hasCompleted = true;

});

});

equal(4, i);

equal(0, sum);

ok(sawError);

ok(!hasCompleted);

});

test('Do_NextErrorCompletedNever', function () {

var hasCompleted, i, sawError, scheduler;

scheduler = new TestScheduler();

i = 0;

sawError = false;

hasCompleted = false;

scheduler.startWithCreate(function () {

return Rx.Observable.never().doAction(function (x) {

i++;

}, function (e) {

sawError = true;

}, function () {

hasCompleted = true;

});

});

equal(0, i);

ok(!sawError);

ok(!hasCompleted);

});

test('Do_Observer_SomeDataWithError', function () {

var ex, hasCompleted, i, sawError, scheduler, sum, xs;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onError(250, ex));

i = 0;

sum = 2 + 3 + 4 + 5;

sawError = false;

hasCompleted = false;

scheduler.startWithCreate(function () {

return xs.doAction(Rx.Observer.create(function (x) {

i++;

sum -= x;

}, function (e) {

sawError = e === ex;

}, function () {

hasCompleted = true;

}));

});

equal(4, i);

equal(0, sum);

ok(sawError);

ok(!hasCompleted);

});

test('Do_Observer_SomeDataWithError', function () {

var hasCompleted, i, sawError, scheduler, sum, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onNext(220, 3), onNext(230, 4), onNext(240, 5), onCompleted(250));

i = 0;

sum = 2 + 3 + 4 + 5;

sawError = false;

hasCompleted = false;

scheduler.startWithCreate(function () {

return xs.doAction(Rx.Observer.create(function (x) {

i++;

sum -= x;

}, function (e) {

sawError = true;

}, function () {

hasCompleted = true;

}));

});

equal(4, i);

equal(0, sum);

ok(!sawError);

ok(hasCompleted);

});

test('Do1422_Next_NextThrows', function () {

var ex, results, scheduler, xs;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.doAction(function () {

throw ex;

});

});

results.messages.assertEqual(onError(210, ex));

});

test('Do1422_NextCompleted_NextThrows', function () {

var ex, results, scheduler, xs, _undefined;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.doAction(function () {

throw ex;

}, _undefined, function () { });

});

results.messages.assertEqual(onError(210, ex));

});

test('Do1422_NextCompleted_CompletedThrows', function () {

var ex, results, scheduler, xs, _undefined;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.doAction(function () { }, _undefined, function () {

throw ex;

});

});

results.messages.assertEqual(onNext(210, 2), onError(250, ex));

});

test('Do1422_NextError_NextThrows', function () {

var ex, results, scheduler, xs;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.doAction(function () {

throw ex;

}, function () { });

});

results.messages.assertEqual(onError(210, ex));

});

test('Do1422_NextError_NextThrows', function () {

var ex1, ex2, results, scheduler, xs;

ex1 = 'ex1';

ex2 = 'ex2';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onError(210, ex1));

results = scheduler.startWithCreate(function () {

return xs.doAction(function () { }, function () {

throw ex2;

});

});

results.messages.assertEqual(onError(210, ex2));

});

test('Do1422_NextErrorCompleted_NextThrows', function () {

var ex, results, scheduler, xs;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.doAction(function () {

throw ex;

}, function () { }, function () { });

});

results.messages.assertEqual(onError(210, ex));

});

test('Do1422_NextErrorCompleted_ErrorThrows', function () {

var ex1, ex2, results, scheduler, xs;

ex1 = 'ex1';

ex2 = 'ex2';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onError(210, ex1));

results = scheduler.startWithCreate(function () {

return xs.doAction(function () { }, function () {

throw ex2;

}, function () { });

});

results.messages.assertEqual(onError(210, ex2));

});

test('Do1422_NextErrorCompleted_CompletedThrows', function () {

var ex, results, scheduler, xs;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.doAction(function () { }, function () { }, function () {

throw ex;

});

});

results.messages.assertEqual(onNext(210, 2), onError(250, ex));

});

test('Do1422_Observer_NextThrows', function () {

var ex, results, scheduler, xs;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.doAction(Rx.Observer.create(function () {

throw ex;

}, function () { }, function () { }));

});

results.messages.assertEqual(onError(210, ex));

});

test('Do1422_Observer_ErrorThrows', function () {

var ex1, ex2, results, scheduler, xs;

ex1 = 'ex1';

ex2 = 'ex2';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onError(210, ex1));

results = scheduler.startWithCreate(function () {

return xs.doAction(Rx.Observer.create(function () { }, function () {

throw ex2;

}, function () { }));

});

results.messages.assertEqual(onError(210, ex2));

});

test('Do1422_Observer_CompletedThrows', function () {

var ex, results, scheduler, xs;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(150, 1), onNext(210, 2), onCompleted(250));

results = scheduler.startWithCreate(function () {

return xs.doAction(Rx.Observer.create(function () { }, function () { }, function () {

throw ex;

}));

});

results.messages.assertEqual(onNext(210, 2), onError(250, ex));

});

test('TakeLast_Zero_Completed', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(180, 1), onNext(210, 2), onNext(250, 3), onNext(270, 4), onNext(310, 5), onNext(360, 6), onNext(380, 7), onNext(410, 8), onNext(590, 9), onCompleted(650));

results = scheduler.startWithCreate(function () {

return xs.takeLast(0);

});

results.messages.assertEqual(onCompleted(650));

xs.subscriptions.assertEqual(subscribe(200, 650));

});

test('TakeLast_Zero_Error', function () {

var ex, results, scheduler, xs;

ex = 'ex';

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(180, 1), onNext(210, 2), onNext(250, 3), onNext(270, 4), onNext(310, 5), onNext(360, 6), onNext(380, 7), onNext(410, 8), onNext(590, 9), onError(650, ex));

results = scheduler.startWithCreate(function () {

return xs.takeLast(0);

});

results.messages.assertEqual(onError(650, ex));

xs.subscriptions.assertEqual(subscribe(200, 650));

});

test('TakeLast_Zero_Disposed', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(180, 1), onNext(210, 2), onNext(250, 3), onNext(270, 4), onNext(310, 5), onNext(360, 6), onNext(380, 7), onNext(410, 8), onNext(590, 9));

results = scheduler.startWithCreate(function () {

return xs.takeLast(0);

});

results.messages.assertEqual();

xs.subscriptions.assertEqual(subscribe(200, 1000));

});

test('TakeLast_One_Completed', function () {

var results, scheduler, xs;

scheduler = new TestScheduler();

xs = scheduler.createHotObservable(onNext(180, 1), onNext(210, 2), onNext(250, 3), onNext(270, 4), onNext(310, 5), onNext(360, 6), onNext(380, 7), onNext(410, 8), onNext(590, 9), onCompleted(650));

results = scheduler.startWithCreate(function () {

return xs.takeLast(1);

});

results.messages.assertEqual(onNext(650, 9), onCompleted(650));

xs.subscriptions.assertEqual(subscribe(200, 650));

});

test('TakeLast_One_Error', function () {

var ex, results, scheduler, xs;

ex = 'ex';

scheduler = new TestScheduler();