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

result types

Browse Source
This commit is contained in:
Jaremy Creechley 2023-09-26 17:26:41 -07:00
parent c1f5d43775
commit da740f1bc8
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
datastore/threads/threadproxyds.nim
View File

@ -202,10 +202,11 @@ method put*(self: ThreadDatastore,
without signal =? acquireSignal(), err: without signal =? acquireSignal(), err:
return failure err return failure err
let key = KeyId.new key.id()
let data = DataBuffer.new data
dispatchTask[void](self, signal): dispatchTask[void](self, signal):
let key = KeyId.new key.id()
let data = DataBuffer.new data
self.tp.spawn putTask(ctx, ds, key, data) self.tp.spawn putTask(ctx, ds, key, data)
return ctx[].res.toRes() return ctx[].res.toRes()
method put*( method put*(
@ -221,8 +222,6 @@ proc getTask[DB](ctx: TaskCtx[DataBuffer], ds: DB;
## run backend command ## run backend command
executeTask(ctx): executeTask(ctx):
let res = get(ds, key) let res = get(ds, key)
static:
echo "getTask:type: ", res.typeof
res res
method get*(self: ThreadDatastore, method get*(self: ThreadDatastore,
@ -235,6 +234,7 @@ method get*(self: ThreadDatastore,
let key = KeyId.new key.id() let key = KeyId.new key.id()
dispatchTask[DataBuffer](self, signal): dispatchTask[DataBuffer](self, signal):
self.tp.spawn getTask(ctx, ds, key) self.tp.spawn getTask(ctx, ds, key)
return ctx[].res.toRes(v => v.toSeq()) return ctx[].res.toRes(v => v.toSeq())
method close*(self: ThreadDatastore): Future[?!void] {.async.} = method close*(self: ThreadDatastore): Future[?!void] {.async.} =