logos-storage/logos-storage-nim
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-nim.git synced 2026-05-03 10:03:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

formatting

Browse Source
This commit is contained in:
Marcin Czenko 2025-06-24 12:55:15 +02:00
parent bbadf63f6b
commit f2f7059a78
No known key found for this signature in database
GPG Key ID: 33DEA0C8E30937C0
3 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
codex/erasure/erasure.nim
View File

@ -565,7 +565,6 @@ proc asyncDecode*(
proc decodeInternal( proc decodeInternal(
self: Erasure, encoded: Manifest self: Erasure, encoded: Manifest
): Future[?!(ref seq[Cid], seq[Natural])] {.async: (raises: [CancelledError]).} = ): Future[?!(ref seq[Cid], seq[Natural])] {.async: (raises: [CancelledError]).} =
logScope: logScope:
steps = encoded.steps steps = encoded.steps
rounded_blocks = encoded.rounded rounded_blocks = encoded.rounded

4
codex/stores/blockstore.nim
View File

@ -154,7 +154,9 @@ method hasBlock*(
method listBlocks*( method listBlocks*(
self: BlockStore, blockType = BlockType.Manifest self: BlockStore, blockType = BlockType.Manifest
): Future[?!AsyncResultIterator[Cid]] {.base, async: (raises: [CancelledError]), gcsafe.} = ): Future[?!AsyncResultIterator[Cid]] {.
base, async: (raises: [CancelledError]), gcsafe
.} =
## Get the list of blocks in the BlockStore. This is an intensive operation ## Get the list of blocks in the BlockStore. This is an intensive operation
## ##

3
tests/codex/utils/testsafeasynciter.nim
View File

@ -37,7 +37,8 @@ asyncchecksuite "Test AsyncResultIterator":
check collected == expectedSeq check collected == expectedSeq
let nextRes = await iter.next() let nextRes = await iter.next()
assert nextRes.isFailure assert nextRes.isFailure
check nextRes.error.msg == "AsyncResultIterator is finished but next item was requested" check nextRes.error.msg ==
"AsyncResultIterator is finished but next item was requested"
test "getting async iter for simple sync range iterator": test "getting async iter for simple sync range iterator":
let iter1 = AsyncResultIterator[int].new(0 ..< 5) let iter1 = AsyncResultIterator[int].new(0 ..< 5)