mirrors/prosody
1
0
Fork 0
mirror of https://github.com/bjc/prosody.git synced 2025-04-03 21:27:38 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

util.promise: Add tests ensuring returning a promise resolves the current promise with that promise

Browse source
This commit is contained in:
Matthew Wild 2018-10-26 09:23:00 +01:00
parent fb6abdb161
commit 37bedc7314
1 changed files with 49 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

49
spec/util_promise_spec.lua
View file

@ -201,6 +201,55 @@ describe("util.promise", function ()
assert.spy(cb2_err).was_called_with("foo");
end);
describe("allows callbacks to return", function ()
it("pending promises", function ()
local r;
local p = promise.resolve()
local cb = spy.new(function ()
return promise.new(function (resolve)
r = resolve;
end);
end);
local cb2 = spy.new(function () end);
p:next(cb):next(cb2);
assert.spy(cb).was_called(1);
assert.spy(cb2).was_called(0);
r("hello");
assert.spy(cb).was_called(1);
assert.spy(cb2).was_called(1);
assert.spy(cb2).was_called_with("hello");
end);
it("resolved promises", function ()
local p = promise.resolve()
local cb = spy.new(function ()
return promise.resolve("hello");
end);
local cb2 = spy.new(function () end);
p:next(cb):next(cb2);
assert.spy(cb).was_called(1);
assert.spy(cb2).was_called(1);
assert.spy(cb2).was_called_with("hello");
end);
it("rejected promises", function ()
local p = promise.resolve()
local cb = spy.new(function ()
return promise.reject("hello");
end);
local cb2 = spy.new(function ()
return promise.reject("goodbye");
end);
local cb3 = spy.new(function () end);
p:next(cb):catch(cb2):catch(cb3);
assert.spy(cb).was_called(1);
assert.spy(cb2).was_called(1);
assert.spy(cb2).was_called_with("hello");
assert.spy(cb3).was_called(1);
assert.spy(cb3).was_called_with("goodbye");
end);
end);
describe("race()", function ()
it("works with fulfilled promises", function ()
local p1, p2 = promise.resolve("yep"), promise.resolve("nope");