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 /util/promise.lua | |
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 'util/promise.lua')
-rw-r--r-- | util/promise.lua | 11 |
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; |