5054c14490
* Adjust empty line count * Implement vim.api.nvim_create_autocmd (#844) * Implement vim.api.nvim_create_autocmd * Only use vim.api.nvim_create_autocmd on nighly * Cleanup * cleanup * Rename autos.lua to autocmds.lua * Fix forgot to rename autos to autocmds * Remove legacy autocmd * Add descriptions on autocmds * Update descriptions on autocmds * Update CmpStatus command to lua API (#922) Signed-off-by: Micah Halter <micah@balena.io> * Move highlights to nvim_set_hl lua API (#925) Signed-off-by: Micah Halter <micah@balena.io> * Add default to highlight * Refactor autocmds * fmt * Improve performance * Fix bug * Improve matching logic Fixes https://github.com/hrsh7th/nvim-cmp/discussions/954 * Fix format * Improve performance Fix #825 * Fix cmdline redraw bug * Fix event Co-authored-by: hrsh7th <> Co-authored-by: zer09 <zer09@users.noreply.github.com> Co-authored-by: Micah Halter <micah@mehalter.com>
130 lines
2.6 KiB
Lua
130 lines
2.6 KiB
Lua
local feedkeys = require('cmp.utils.feedkeys')
|
|
|
|
local async = {}
|
|
|
|
---@class cmp.AsyncThrottle
|
|
---@field public running boolean
|
|
---@field public timeout number
|
|
---@field public sync function(self: cmp.AsyncThrottle, timeout: number|nil)
|
|
---@field public stop function
|
|
---@field public __call function
|
|
|
|
---@param fn function
|
|
---@param timeout number
|
|
---@return cmp.AsyncThrottle
|
|
async.throttle = function(fn, timeout)
|
|
local time = nil
|
|
local timer = vim.loop.new_timer()
|
|
return setmetatable({
|
|
running = false,
|
|
timeout = timeout,
|
|
sync = function(self, timeout_)
|
|
vim.wait(timeout_ or 1000, function()
|
|
return not self.running
|
|
end)
|
|
end,
|
|
stop = function()
|
|
time = nil
|
|
timer:stop()
|
|
end,
|
|
}, {
|
|
__call = function(self, ...)
|
|
local args = { ... }
|
|
|
|
if time == nil then
|
|
time = vim.loop.now()
|
|
end
|
|
|
|
self.running = true
|
|
timer:stop()
|
|
timer:start(math.max(1, self.timeout - (vim.loop.now() - time)), 0, function()
|
|
vim.schedule(function()
|
|
time = nil
|
|
fn(unpack(args))
|
|
self.running = false
|
|
end)
|
|
end)
|
|
end,
|
|
})
|
|
end
|
|
|
|
---Control async tasks.
|
|
async.step = function(...)
|
|
local tasks = { ... }
|
|
local next
|
|
next = function(...)
|
|
if #tasks > 0 then
|
|
table.remove(tasks, 1)(next, ...)
|
|
end
|
|
end
|
|
table.remove(tasks, 1)(next)
|
|
end
|
|
|
|
---Timeout callback function
|
|
---@param fn function
|
|
---@param timeout number
|
|
---@return function
|
|
async.timeout = function(fn, timeout)
|
|
local timer
|
|
local done = false
|
|
local callback = function(...)
|
|
if not done then
|
|
done = true
|
|
timer:stop()
|
|
timer:close()
|
|
fn(...)
|
|
end
|
|
end
|
|
timer = vim.loop.new_timer()
|
|
timer:start(timeout, 0, function()
|
|
callback()
|
|
end)
|
|
return callback
|
|
end
|
|
|
|
---@alias cmp.AsyncDedup fun(callback: function): function
|
|
|
|
---Create deduplicated callback
|
|
---@return function
|
|
async.dedup = function()
|
|
local id = 0
|
|
return function(callback)
|
|
id = id + 1
|
|
|
|
local current = id
|
|
return function(...)
|
|
if current == id then
|
|
callback(...)
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
---Convert async process as sync
|
|
async.sync = function(runner, timeout)
|
|
local done = false
|
|
runner(function()
|
|
done = true
|
|
end)
|
|
vim.wait(timeout, function()
|
|
return done
|
|
end, 10, false)
|
|
end
|
|
|
|
---Wait and callback for next safe state.
|
|
async.debounce_safe_state = function(callback)
|
|
local running = false
|
|
return function()
|
|
if running then
|
|
return
|
|
end
|
|
running = true
|
|
feedkeys.call('', 'n', function()
|
|
running = false
|
|
callback()
|
|
end)
|
|
end
|
|
end
|
|
|
|
return async
|