|
1 | | -local validator = require('orgmode.utils.validator') |
2 | 1 | ---@diagnostic disable: undefined-field |
3 | 2 | -- Taken from https://github.com/notomo/promise.nvim |
4 | 3 |
|
@@ -46,8 +45,8 @@ local new_empty_userdata = function() |
46 | 45 | end |
47 | 46 |
|
48 | 47 | local new_pending = function(on_fullfilled, on_rejected) |
49 | | - validator.validate('on_fullfilled', on_fullfilled, 'function', true) |
50 | | - validator.validate('on_rejected', on_rejected, 'function', true) |
| 48 | + vim.validate('on_fullfilled', on_fullfilled, 'function', true) |
| 49 | + vim.validate('on_rejected', on_rejected, 'function', true) |
51 | 50 | local tbl = { |
52 | 51 | _status = PromiseStatus.Pending, |
53 | 52 | _queued = {}, |
|
84 | 83 | --- @param executor fun(resolve:fun(...:any),reject:fun(...:any)) |
85 | 84 | --- @return OrgPromise |
86 | 85 | function Promise.new(executor) |
87 | | - validator.validate('executor', executor, 'function') |
| 86 | + vim.validate('executor', executor, 'function') |
88 | 87 |
|
89 | 88 | local self = new_pending() |
90 | 89 |
|
|
224 | 223 | --- @param on_rejected (fun(...:any):any)?: A callback on rejected. |
225 | 224 | --- @return OrgPromise |
226 | 225 | function Promise.next(self, on_fullfilled, on_rejected) |
227 | | - validator.validate('on_fullfilled', on_fullfilled, 'function', true) |
228 | | - validator.validate('on_rejected', on_rejected, 'function', true) |
| 226 | + vim.validate('on_fullfilled', on_fullfilled, 'function', true) |
| 227 | + vim.validate('on_rejected', on_rejected, 'function', true) |
229 | 228 | local promise = new_pending(on_fullfilled, on_rejected) |
230 | 229 | table.insert(self._queued, promise) |
231 | 230 | vim.schedule(function() |
|
250 | 249 | --- @param on_finally fun() |
251 | 250 | --- @return OrgPromise |
252 | 251 | function Promise.finally(self, on_finally) |
253 | | - validator.validate('on_finally', on_finally, 'function', true) |
| 252 | + vim.validate('on_finally', on_finally, 'function', true) |
254 | 253 | return self |
255 | 254 | :next(function(...) |
256 | 255 | on_finally() |
|
310 | 309 | --- @param list any[]: promise or non-promise values |
311 | 310 | --- @return OrgPromise |
312 | 311 | function Promise.all(list) |
313 | | - validator.validate('list', list, 'table') |
| 312 | + vim.validate('list', list, 'table') |
314 | 313 | return Promise.new(function(resolve, reject) |
315 | 314 | local remain = #list |
316 | 315 | if remain == 0 then |
|
341 | 340 | --- @param concurrency? number: limit number of concurrent items processing |
342 | 341 | --- @return OrgPromise |
343 | 342 | function Promise.map(callback, list, concurrency) |
344 | | - validator.validate('list', list, 'table') |
345 | | - validator.validate('callback', callback, 'function') |
346 | | - validator.validate('concurrency', concurrency, 'number', true) |
| 343 | + vim.validate('list', list, 'table') |
| 344 | + vim.validate('callback', callback, 'function') |
| 345 | + vim.validate('concurrency', concurrency, 'number', true) |
347 | 346 |
|
348 | 347 | local results = {} |
349 | 348 | local processing = 0 |
|
392 | 391 | --- @param list any[]: promise or non-promise values |
393 | 392 | --- @return OrgPromise |
394 | 393 | function Promise.race(list) |
395 | | - validator.validate('list', list, 'table') |
| 394 | + vim.validate('list', list, 'table') |
396 | 395 | return Promise.new(function(resolve, reject) |
397 | 396 | for _, e in ipairs(list) do |
398 | 397 | Promise.resolve(e) |
|
411 | 410 | --- @param list any[]: promise or non-promise values |
412 | 411 | --- @return OrgPromise |
413 | 412 | function Promise.any(list) |
414 | | - validator.validate('list', list, 'table') |
| 413 | + vim.validate('list', list, 'table') |
415 | 414 | return Promise.new(function(resolve, reject) |
416 | 415 | local remain = #list |
417 | 416 | if remain == 0 then |
|
441 | 440 | --- @param list any[]: promise or non-promise values |
442 | 441 | --- @return OrgPromise |
443 | 442 | function Promise.all_settled(list) |
444 | | - validator.validate('list', list, 'table') |
| 443 | + vim.validate('list', list, 'table') |
445 | 444 | return Promise.new(function(resolve) |
446 | 445 | local remain = #list |
447 | 446 | if remain == 0 then |
|
0 commit comments