64e59060b1
* something kind of works already * yayayayayayayayayayayayayayayayayayayayayayayayayayayayayayayayaya * use async for everything besides live jobs * fix: fixup autocmds previewer * fix: lints for prime * temp: Add example of how we can think about async sorters * feat: Allow picker to decide when to cancel * fix: simplify scoring logic and tests * fixup: name * fix: Move back towards more backwards compat methods * fixup: Remove results from opts * fixup: remove trailing quote * fixup: Attempt to clean up some more async items. Next is status * wip: Add todo for when bfredl implements extmarks over the EOL * wip * fixup: got em * fixup: cleaning * fixup: docs
74 lines
1.8 KiB
Lua
74 lines
1.8 KiB
Lua
local log = require('telescope.log')
|
|
local Job = require('plenary.job')
|
|
|
|
local async_lib = require('plenary.async_lib')
|
|
local async = async_lib.async
|
|
-- local await = async_lib.await
|
|
local void = async_lib.void
|
|
|
|
local make_entry = require('telescope.make_entry')
|
|
|
|
return function(opts)
|
|
local entry_maker = opts.entry_maker or make_entry.gen_from_string()
|
|
local fn_command = function(prompt)
|
|
local command_list = opts.command_generator(prompt)
|
|
if command_list == nil then
|
|
return nil
|
|
end
|
|
|
|
local command = table.remove(command_list, 1)
|
|
|
|
return {
|
|
command = command,
|
|
args = command_list,
|
|
}
|
|
end
|
|
|
|
local job
|
|
return setmetatable({
|
|
close = function() end,
|
|
}, {
|
|
__call = void(async(function(prompt, process_result, process_complete)
|
|
print("are we callin anything?", job)
|
|
if job and not job.is_shutdown then
|
|
log.debug("Shutting down old job")
|
|
job:shutdown()
|
|
end
|
|
|
|
local job_opts = fn_command(prompt)
|
|
if not job_opts then return end
|
|
|
|
local writer = nil
|
|
if job_opts.writer and Job.is_job(job_opts.writer) then
|
|
writer = job_opts.writer
|
|
elseif opts.writer then
|
|
writer = Job:new(job_opts.writer)
|
|
end
|
|
|
|
job = Job:new {
|
|
command = job_opts.command,
|
|
args = job_opts.args,
|
|
cwd = job_opts.cwd or opts.cwd,
|
|
maximum_results = opts.maximum_results,
|
|
writer = writer,
|
|
enable_recording = false,
|
|
|
|
on_stdout = vim.schedule_wrap(function(_, line)
|
|
if not line or line == "" then
|
|
return
|
|
end
|
|
|
|
-- TODO: shutdown job here.
|
|
process_result(entry_maker(line))
|
|
end),
|
|
|
|
on_exit = function()
|
|
process_complete()
|
|
end,
|
|
}
|
|
|
|
job:start()
|
|
end)),
|
|
})
|
|
end
|