aboutsummaryrefslogtreecommitdiffstats
path: root/util/promise.lua
diff options
context:
space:
mode:
authorMatthew Wild <mwild1@gmail.com>2021-03-25 14:28:38 +0000
committerMatthew Wild <mwild1@gmail.com>2021-03-25 14:28:38 +0000
commit2141d9d94a7b0c855a99e4444b093f80ee316f75 (patch)
tree0f3fc3868b801255a9ecfef57847d4ccafbcc315 /util/promise.lua
parent3952fae8ce728d56b9ef2044e490d99a6c12f444 (diff)
downloadprosody-2141d9d94a7b0c855a99e4444b093f80ee316f75.tar.gz
prosody-2141d9d94a7b0c855a99e4444b093f80ee316f75.zip
util.promise: Add join() convenience method
Usage: promise.join(p1, p2, function (result1, result2) [...] end)
Diffstat (limited to 'util/promise.lua')
-rw-r--r--util/promise.lua11
1 files changed, 11 insertions, 0 deletions
diff --git a/util/promise.lua b/util/promise.lua
index 98d313ba..5996176f 100644
--- a/util/promise.lua
+++ b/util/promise.lua
@@ -2,6 +2,7 @@ local promise_methods = {};
local promise_mt = { __name = "promise", __index = promise_methods };
local xpcall = require "util.xpcall".xpcall;
+local unpack = table.unpack or unpack; --luacheck: ignore 113
function promise_mt:__tostring()
return "promise (" .. (self._state or "invalid") .. ")";
@@ -137,6 +138,15 @@ local function all_settled(promises)
end);
end
+local function join(...)
+ local promises, n = { ... }, select("#", ...);
+ local handler = promises[n];
+ promises[n] = nil;
+ return all(promises):next(function (results)
+ return handler(unpack(results, 1, n - 1));
+ end);
+end
+
local function race(promises)
return new(function (resolve, reject)
for i = 1, #promises do
@@ -180,6 +190,7 @@ end
return {
new = new;
resolve = resolve;
+ join = join;
reject = reject;
all = all;
all_settled = all_settled;