changes the module name: safeasynciter => asyncresultiterator

codex/stores/maintenance.nim

@@ -18,7 +18,7 @@ import pkg/questionable/results
 
 import ./repostore
 import ../utils/timer
-import ../utils/safeasynciter
+import ../utils/asyncresultiterator
 import ../clock
 import ../logutils
 import ../systemclock

codex/stores/networkstore.nim

@@ -19,7 +19,7 @@ import ../blockexchange
 import ../logutils
 import ../merkletree
 import ../utils/asyncheapqueue
-import ../utils/safeasynciter
+import ../utils/asyncresultiterator
 import ./blockstore
 
 export blockstore, blockexchange, asyncheapqueue

codex/stores/queryiterhelper.nim

@@ -4,7 +4,7 @@ import pkg/chronos
 import pkg/chronicles
 import pkg/datastore/typedds
 
-import ../utils/safeasynciter
+import ../utils/asyncresultiterator
 
 {.push raises: [].}
 

codex/utils.nim

@@ -19,9 +19,9 @@ import pkg/chronos
 import ./utils/asyncheapqueue
 import ./utils/fileutils
 import ./utils/iter
-import ./utils/safeasynciter
+import ./utils/asyncresultiterator
 
-export asyncheapqueue, fileutils, iter, safeasynciter, chronos
+export asyncheapqueue, fileutils, iter, asyncresultiterator, chronos
 
 when defined(posix):
   import os, posix

tests/codex/helpers/mockrepostore.nim

@@ -14,7 +14,7 @@ import pkg/questionable
 import pkg/questionable/results
 
 import pkg/codex/stores/repostore
-import pkg/codex/utils/safeasynciter
+import pkg/codex/utils/asyncresultiterator
 
 type MockRepoStore* = ref object of RepoStore
   delBlockCids*: seq[Cid]

tests/codex/stores/testqueryiterhelper.nim

@@ -6,7 +6,7 @@ import pkg/chronos
 import pkg/datastore/typedds
 import pkg/datastore/sql/sqliteds
 import pkg/codex/stores/queryiterhelper
-import pkg/codex/utils/safeasynciter
+import pkg/codex/utils/asyncresultiterator
 
 import ../../asynctest
 import ../helpers

tests/codex/stores/testrepostore.nim

@@ -15,7 +15,7 @@ import pkg/codex/stores
 import pkg/codex/stores/repostore/operations
 import pkg/codex/blocktype as bt
 import pkg/codex/clock
-import pkg/codex/utils/safeasynciter
+import pkg/codex/utils/asyncresultiterator
 import pkg/codex/merkletree/codex
 
 import ../../asynctest

tests/codex/testutils.nim

@@ -1,7 +1,7 @@
 import ./utils/testoptions
 import ./utils/testkeyutils
 import ./utils/testasyncstatemachine
-import ./utils/testsafeasynciter
+import ./utils/testasyncresultiterator
 import ./utils/testtimer
 import ./utils/testtrackedfutures
 

tests/codex/utils/testasyncresultiterator.nim

@@ -2,7 +2,7 @@ import std/sugar
 import pkg/questionable
 import pkg/chronos
 import pkg/codex/utils/iter
-import pkg/codex/utils/safeasynciter
+import pkg/codex/utils/asyncresultiterator
 
 import ../../asynctest
 import ../helpers
@@ -383,7 +383,7 @@ asyncchecksuite "Test AsyncResultIterator":
     # cancellation of the async predicate function.
 
     let fut: Future[Option[?!string]].Raising([CancelledError]) =
-      Future[Option[?!string]].Raising([CancelledError]).init("testsafeasynciter")
+      Future[Option[?!string]].Raising([CancelledError]).init("testasyncresultiterator")
 
     let iter1 = AsyncResultIterator[int].new(0 ..< 5).delayBy(10.millis)
     let iter2 = await mapFilter[int, string](