mirror of
https://github.com/neovim/neovim.git
synced 2026-09-09 15:35:51 +00:00
65ef6fdaee
Problem: LuaLS struggles with the generics used in Nvim's runtime, requiring broad diagnostic suppressions. Indexing is also slow. Solution: Use EmmyLua for type checks in the build and CI. It offers more sophisticated type checking, substantially better support for generics, and much better flow analysis. Correct the affected annotations. Use `@internal`, supported directly by EmmyLua, instead of `@nodoc` for shared internal declarations, and support it in the help parser. AI-assisted
85 lines
1.8 KiB
Lua
85 lines
1.8 KiB
Lua
local F = vim.F
|
|
local util = require('vim._core.util')
|
|
|
|
--- @class (internal) vim.async.Future<R>
|
|
--- @field private _callbacks table<integer, fun(err?: any, ...: R...)>
|
|
--- @field private _callback_pos integer
|
|
--- @field private _err? any
|
|
--- @field private _result? R[] & { n: integer }
|
|
local Future = {}
|
|
Future.__index = Future
|
|
|
|
function Future:completed()
|
|
return self._err ~= nil or self._result ~= nil
|
|
end
|
|
|
|
function Future:result()
|
|
if not self:completed() then
|
|
error('Future has not completed', 2)
|
|
end
|
|
if self._err ~= nil then
|
|
return false, self._err
|
|
else
|
|
return true, F.unpack_len(self._result)
|
|
end
|
|
end
|
|
|
|
--- @param callback fun(err?: any, ...: R...)
|
|
--- @return fun()
|
|
function Future:on_complete(callback)
|
|
if self:completed() then
|
|
-- Already completed or closed
|
|
if self._err ~= nil then
|
|
callback(self._err)
|
|
else
|
|
callback(nil, F.unpack_len(self._result))
|
|
end
|
|
return function() end
|
|
end
|
|
|
|
local id = self._callback_pos
|
|
self._callback_pos = id + 1
|
|
self._callbacks[id] = callback
|
|
|
|
return function()
|
|
self._callbacks[id] = nil
|
|
end
|
|
end
|
|
|
|
--- @param err? any
|
|
--- @param ... R...
|
|
function Future:complete(err, ...)
|
|
if self:completed() then
|
|
error('Future is already completed', 2)
|
|
end
|
|
|
|
if err ~= nil then
|
|
self._err = err
|
|
else
|
|
self._result = F.pack_len(...)
|
|
end
|
|
|
|
local callbacks = self._callbacks
|
|
self._callbacks = {}
|
|
|
|
local errs = {} -- Need to use pairs to avoid gaps caused by removed callbacks
|
|
for _, cb in pairs(callbacks) do
|
|
local ok, cb_err = pcall(cb, err, ...)
|
|
if not ok then
|
|
errs[#errs + 1] = util._stringify_error(util._normalize_error(cb_err))
|
|
end
|
|
end
|
|
|
|
if #errs > 0 then
|
|
error(table.concat(errs, '\n'), 0)
|
|
end
|
|
end
|
|
|
|
--- @return vim.async.Future<any>
|
|
return function()
|
|
return setmetatable({
|
|
_callbacks = {},
|
|
_callback_pos = 1,
|
|
}, Future)
|
|
end
|