mirrors/neovim
1
0
Fork 0
mirror of https://github.com/neovim/neovim.git synced 2026-07-17 22:51:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(server_notifications_spec): improve chanclose test (#37337)

Browse Source 
Check that a pending event is actually cancelled, in place of the
nvim_subscribe that was removed in #28487.
This commit is contained in:
zeertzjq
2026-01-10 12:12:06 +08:00
committed by GitHub
parent 295fb3fdb2
commit cb77bd1b86
1 changed files with 10 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
test/functional/api/server_notifications_spec.lua
View File

@@ -80,23 +80,25 @@ describe('notify', function()
it('cancels stale events on channel close #13537', function()
local catchan = eval("jobstart(['cat'], {'rpc': v:true})")
local catpath = eval('exepath("cat")')
api.nvim_set_var('somevar', 0)
eq(
{ id = catchan, argv = { catpath }, stream = 'job', mode = 'rpc', client = {} },
exec_lua(
[[
vim.rpcnotify(..., "nvim_call_function", 'chanclose', {..., 'rpc'})
return vim.api.nvim_get_chan_info(...)
]],
catchan
)
exec_lua(function()
vim.rpcnotify(catchan, 'nvim_call_function', 'chanclose', { catchan, 'rpc' })
vim.rpcnotify(catchan, 'nvim_set_var', 'somevar', 1) -- Should be cancelled.
return vim.api.nvim_get_chan_info(catchan)
end)
)
assert_alive()
eq(
{ false, 'Invalid channel: ' .. catchan },
exec_lua([[ return {pcall(vim.rpcrequest, ..., 'nvim_eval', '1+1')}]], catchan)
exec_lua(function()
return { pcall(vim.rpcrequest, catchan, 'nvim_eval', '1+1') }
end, catchan)
)
retry(nil, 3000, function()
eq({}, api.nvim_get_chan_info(catchan))
end) -- cat be dead :(
eq(0, api.nvim_get_var('somevar'))
end)
end)