Dereku/snappymail
1
0
Fork 0
mirror of https://github.com/the-djmaze/snappymail.git synced 2026-09-04 23:17:02 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

Promises (first look)

Browse source 
Thread dropdown
Small fixes
This commit is contained in:
RainLoop Team 2015-03-14 03:10:00 +04:00
parent dd41d30f9b
commit c23ba31e17
61 changed files with 12442 additions and 130 deletions
Download patch file Download diff file Expand all files Collapse all files

180
vendors/Q/spec/queue-spec.js vendored Normal file
View file

@ -0,0 +1,180 @@
var Q = require("../q");
var Queue = require("../queue");
global.Q = Q;
require("./lib/jasmine-promise");
describe("queue", function () {
it("should enqueue then dequeue", function () {
var queue = Queue();
queue.put(1);
return queue.get().then(function (value) {
expect(value).toBe(1);
});
});
it("should dequeue then enqueue", function () {
var queue = Queue();
var promise = queue.get().then(function (value) {
expect(value).toBe(1);
});
queue.put(1);
return promise;
});
it("should stream", function () {
var queue = Queue();
Q.try(function () {
return Q.delay(20).then(function () {
queue.put(1);
})
})
.then(function () {
return Q.delay(20).then(function () {
queue.put(2);
})
})
.then(function () {
return Q.delay(20).then(function () {
queue.put(3);
})
})
.done();
return Q.try(function () {
return queue.get()
.then(function (value) {
expect(value).toBe(1);
});
})
.then(function () {
return queue.get()
.then(function (value) {
expect(value).toBe(2);
});
})
.then(function () {
return queue.get()
.then(function (value) {
expect(value).toBe(3);
});
})
});
it("should be order agnostic", function () {
var queue = Queue();
Q.try(function () {
return Q.delay(20).then(function () {
queue.put(1);
})
})
.then(function () {
return Q.delay(20).then(function () {
queue.put(2);
})
})
.then(function () {
return Q.delay(20).then(function () {
queue.put(3);
})
})
.done();
return Q.all([
queue.get()
.then(function (value) {
expect(value).toBe(1);
}),
queue.get()
.then(function (value) {
expect(value).toBe(2);
}),
queue.get()
.then(function (value) {
expect(value).toBe(3);
})
]);
});
it("should close", function () {
var queue = Queue();
Q.try(function () {
return Q.delay(20).then(function () {
queue.put(1);
})
})
.then(function () {
return Q.delay(20).then(function () {
queue.put(2);
})
})
.then(function () {
queue.close();
})
.done();
return Q.try(function () {
return queue.get()
.then(function (value) {
expect(value).toBe(1);
});
})
.then(function () {
return queue.get()
.then(function (value) {
expect(value).toBe(2);
});
})
.then(function () {
return queue.get()
.then(function (value) {
expect(false).toBe(true); // should not get here
});
})
.catch(function (error) {
expect(error.message).toBe("Can't get value from closed queue");
return queue.get();
})
.catch(function (error) {
expect(error.message).toBe("Can't get value from closed queue");
})
.then(function () {
return queue.closed;
})
.then(function (error) {
expect(error.message).toBe("Can't get value from closed queue");
})
});
it("should close with alternate error", function () {
var queue = Queue();
queue.close(new Error("Alternate reason"));
return Q.try(function () {
return queue.get();
})
.catch(function (error) {
expect(error.message).toBe("Alternate reason");
return queue.get();
})
.catch(function (error) {
expect(error.message).toBe("Alternate reason");
})
.then(function () {
return queue.closed;
})
.then(function (error) {
expect(error.message).toBe("Alternate reason");
})
});
});