return Promise

luozhiya · Feb 7, 2025 · ac634b0 · ac634b0
1 parent ab68367
commit ac634b0
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 29 deletions.
diff --git a/lua/fittencode/async_hash/engines/purelua/init.lua b/lua/fittencode/async_hash/engines/purelua/init.lua
@@ -56,35 +56,13 @@ function M.hash(algorithm, data, options)
         (type(data) == 'string' and vim.fn.filereadable(data) == 1)
 
     if is_file then
-        return Promise.new(function(resolve, reject)
-            local hasher = M.create_hasher(algorithm)
-            local chunk_size = 4096
-            local path = data
-
-            FS.read_chunked(path, chunk_size, function(chunk)
-                hasher:update(chunk)
-            end):forward(function() hasher:finalize() end)
-
-            -- local function _read_next(offset)
-            --     vim.uv.fs_read(fd, chunk_size, offset, function(err, chunk)
-            --         if err then
-            --             vim.uv.fs_close(fd)
-            --             return reject(err)
-            --         end
+        local hasher = M.create_hasher(algorithm)
+        local chunk_size = 4096
+        local path = data
 
-            --         if chunk and #chunk > 0 then
-            --             hasher:update(chunk)
-            --             _read_next(offset + #chunk)
-            --         else
-            --             vim.uv.fs_close(fd, function(close_err)
-            --                 if close_err then return reject(close_err) end
-            --                 resolve(hasher:finalize())
-            --             end)
-            --         end
-            --     end)
-            -- end
-            -- _read_next(0)
-        end)
+        return FS.read_chunked(path, chunk_size, function(chunk)
+            hasher:update(chunk)
+        end):forward(function() return hasher:finalize() end)
     else
         local hasher = M.create_hasher(algorithm)
         hasher:update(data)

diff --git a/lua/fittencode/uv/fs.lua b/lua/fittencode/uv/fs.lua
@@ -13,6 +13,7 @@ uv_fs.read_file('test.txt')
 
 local _Promise = require('fittencode.uv._promise')
 local Promise = require('fittencode.concurrency.promise')
+local Fn = require('fittencode.fn')
 
 -- local fs_functions = {
 --     'fs_close', 'fs_open', 'fs_read', 'fs_write', 'fs_unlink', 'fs_mkdir',
@@ -113,7 +114,7 @@ function M.read_chunked(path, chunk_size, on_chunk)
                     :forward(function(packed)
                         local chunk = packed[1]
                         if chunk and #chunk > 0 then
-                            on_chunk(chunk)
+                            Fn.check_call(on_chunk, chunk)
                             return _read_next_chunk()
                         else
                             return M.close(fd)