logos-storage/nim-datastore
1
0
Fork 0
mirror of https://github.com/logos-storage/nim-datastore.git synced 2026-01-08 08:33:10 +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
parent b219971fc5
commit 9033a8ffef
No known key found for this signature in database
GPG Key ID: 69D6CE281FCAE663
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)))
for fut in pending:
try:
if fut.read().isErr:
return fut.read()
except FuturePendingError as err:
return failure err
let res = await fut
if res.isErr: return res
return success()
@ -64,11 +61,8 @@ method delete*(
pending = await allFinished(self.stores.mapIt(it.delete(key)))
for fut in pending:
try:
if fut.read().isErr:
return fut.read()
except FuturePendingError as err:
return failure err
let res = await fut
if res.isErr: return res
return success()
@ -105,11 +99,8 @@ method put*(
pending = await allFinished(self.stores.mapIt(it.put(key, data)))
for fut in pending:
try:
if fut.read().isErr:
return fut.read()
except FuturePendingError as err:
return failure err
let res = await fut
if res.isErr: return res
return success()
@ -122,11 +113,8 @@ method put*(
pending = await allFinished(self.stores.mapIt(it.put(entry.key, entry.data)))
for fut in pending:
try:
if fut.read().isErr:
return fut.read()
except FuturePendingError as err:
return failure err
let res = await fut
if res.isErr: return res
return success()
@ -141,13 +129,9 @@ method modifyGet*(
var aux = newSeq[byte]()
for fut in pending:
try:
if fut.read().isErr:
return fut.read()
else:
aux.add(fut.read().get)
except FuturePendingError as err:
return failure err
let res = await fut
if res.isErr: return res
aux.add(res.get)
return success(aux)
@ -160,11 +144,8 @@ method modify*(
pending = await allFinished(self.stores.mapIt(it.modify(key, fn)))
for fut in pending:
try:
if fut.read().isErr:
return fut.read()
except FuturePendingError as err:
return failure err
let res = await fut
if res.isErr: return res
return success()