logos-storage/nim-datastore
1
0
Fork 0
mirror of https://github.com/logos-storage/nim-datastore.git synced 2026-01-04 06:33:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use await instead of fut.read

Browse Source
This commit is contained in:
Arnaud 2025-03-10 14:52:50 +01:00 committed by Giuliano Mega
parent d583647c5b
commit 950990720a
1 changed files with 13 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
datastore/tieredds.nim
View File

@ -47,11 +47,8 @@ method delete*(
pending = await allFinished(self.stores.mapIt(it.delete(key))) pending = await allFinished(self.stores.mapIt(it.delete(key)))
for fut in pending: for fut in pending:
try: let res = await fut
if fut.read().isErr: if res.isErr: return res
return fut.read()
except FuturePendingError as err:
return failure err
return success() return success()
@ -64,11 +61,8 @@ method delete*(
pending = await allFinished(self.stores.mapIt(it.delete(key))) pending = await allFinished(self.stores.mapIt(it.delete(key)))
for fut in pending: for fut in pending:
try: let res = await fut
if fut.read().isErr: if res.isErr: return res
return fut.read()
except FuturePendingError as err:
return failure err
return success() return success()
@ -105,11 +99,8 @@ method put*(
pending = await allFinished(self.stores.mapIt(it.put(key, data))) pending = await allFinished(self.stores.mapIt(it.put(key, data)))
for fut in pending: for fut in pending:
try: let res = await fut
if fut.read().isErr: if res.isErr: return res
return fut.read()
except FuturePendingError as err:
return failure err
return success() return success()
@ -122,11 +113,8 @@ method put*(
pending = await allFinished(self.stores.mapIt(it.put(entry.key, entry.data))) pending = await allFinished(self.stores.mapIt(it.put(entry.key, entry.data)))
for fut in pending: for fut in pending:
try: let res = await fut
if fut.read().isErr: if res.isErr: return res
return fut.read()
except FuturePendingError as err:
return failure err
return success() return success()
@ -141,13 +129,9 @@ method modifyGet*(
var aux = newSeq[byte]() var aux = newSeq[byte]()
for fut in pending: for fut in pending:
try: let res = await fut
if fut.read().isErr: if res.isErr: return res
return fut.read() aux.add(res.get)
else:
aux.add(fut.read().get)
except FuturePendingError as err:
return failure err
return success(aux) return success(aux)
@ -160,11 +144,8 @@ method modify*(
pending = await allFinished(self.stores.mapIt(it.modify(key, fn))) pending = await allFinished(self.stores.mapIt(it.modify(key, fn)))
for fut in pending: for fut in pending:
try: let res = await fut
if fut.read().isErr: if res.isErr: return res
return fut.read()
except FuturePendingError as err:
return failure err
return success() return success()