From 62bf2e4949edfb595d8beaf9f8d4a6985560fdbe Mon Sep 17 00:00:00 2001 From: Arnaud Date: Mon, 29 Sep 2025 15:17:18 +0200 Subject: [PATCH] Rename OnBlockStored --- codex/node.nim | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/codex/node.nim b/codex/node.nim index 3b05f918..063e90f5 100644 --- a/codex/node.nim +++ b/codex/node.nim @@ -84,8 +84,7 @@ type BatchProc* = proc(blocks: seq[bt.Block]): Future[?!void] {. gcsafe, async: (raises: [CancelledError]) .} - OnBlockStoreProc = - proc(chunk: seq[byte]): Future[void] {.gcsafe, async: (raises: [CancelledError]).} + OnBlockStoredProc = proc(chunk: seq[byte]): void {.gcsafe, raises: [].} func switch*(self: CodexNodeRef): Switch = return self.switch @@ -436,7 +435,7 @@ proc store*( filename: ?string = string.none, mimetype: ?string = string.none, blockSize = DefaultBlockSize, - onBlockStoreProc: OnBlockStoreProc = nil, + onBlockStored: OnBlockStoredProc = nil, ): Future[?!Cid] {.async.} = ## Save stream contents as dataset with given blockSize ## to nodes's BlockStore, and return Cid of its manifest @@ -467,8 +466,8 @@ proc store*( error "Unable to store block", cid = blk.cid, err = err.msg return failure(&"Unable to store block {blk.cid}") - if not onBlockStoreProc.isNil: - discard onBlockStoreProc(chunk) + if not onBlockStored.isNil: + onBlockStored(chunk) except CancelledError as exc: raise exc except CatchableError as exc: