diff options
author | Matthew Wild <mwild1@gmail.com> | 2021-03-25 14:28:38 +0000 |
---|---|---|
committer | Matthew Wild <mwild1@gmail.com> | 2021-03-25 14:28:38 +0000 |
commit | 2141d9d94a7b0c855a99e4444b093f80ee316f75 (patch) | |
tree | 0f3fc3868b801255a9ecfef57847d4ccafbcc315 /spec | |
parent | 3952fae8ce728d56b9ef2044e490d99a6c12f444 (diff) | |
download | prosody-2141d9d94a7b0c855a99e4444b093f80ee316f75.tar.gz prosody-2141d9d94a7b0c855a99e4444b093f80ee316f75.zip |
util.promise: Add join() convenience method
Usage: promise.join(p1, p2, function (result1, result2)
[...]
end)
Diffstat (limited to 'spec')
-rw-r--r-- | spec/util_promise_spec.lua | 26 |
1 files changed, 26 insertions, 0 deletions
diff --git a/spec/util_promise_spec.lua b/spec/util_promise_spec.lua index 4be9b5a0..79eec5e2 100644 --- a/spec/util_promise_spec.lua +++ b/spec/util_promise_spec.lua @@ -459,6 +459,32 @@ describe("util.promise", function () assert.same({ foo = true }, result); end); end); + describe("join()", function () + it("works", function () + local r1, r2; + local res1, res2; + local p1, p2 = promise.new(function (resolve) r1 = resolve end), promise.new(function (resolve) r2 = resolve end); + + local p = promise.join(p1, p2, function (_res1, _res2) + res1, res2 = _res1, _res2; + return promise.resolve("works"); + end); + + local result; + local cb = spy.new(function (v) + result = v; + end); + p:next(cb); + assert.spy(cb).was_called(0); + r2("yep"); + assert.spy(cb).was_called(0); + r1("nope"); + assert.spy(cb).was_called(1); + assert.same("works", result); + assert.equals("nope", res1); + assert.equals("yep", res2); + end); + end); it("promises may be resolved by other promises", function () local r1, r2; local p1, p2 = promise.new(function (resolve) r1 = resolve end), promise.new(function (resolve) r2 = resolve end); |