diff --git a/datastore/threads/threadbackend.nim b/datastore/threads/threadbackend.nim index 0e69f2e..70cae29 100644 --- a/datastore/threads/threadbackend.nim +++ b/datastore/threads/threadbackend.nim @@ -174,14 +174,19 @@ proc put*( echoed "spawn put request: ", $getThreadId() # this spawns the taskpool Task # but we can't wait on it directly - we use wait(ret[].sig) + echo "\n" tds[].tp.spawn putTask(sig, ret, tds, bkey, bval) wait(sig). then(proc () = + echo "\n" + os.sleep(400) + echoed "put request done " var ret = ret let val = ret.convert(void) putRes.complete(val) ).cancelled(proc() = + echoed "put request cancelled " discard ).catch(proc(e: ref CatchableError) = doAssert false, "will not be triggered" @@ -193,6 +198,8 @@ proc put*( putRes.complete(res) ) + return putRes + proc deleteTask*( ret: TResult[void],