diff --git a/library/sds_thread/sds_thread.nim b/library/sds_thread/sds_thread.nim index 4a2cce5..8f23840 100644 --- a/library/sds_thread/sds_thread.nim +++ b/library/sds_thread/sds_thread.nim @@ -41,13 +41,13 @@ proc runSds(ctx: ptr SdsContext) {.async.} = error "sds thread could not receive a request" continue + ## Handle the request + asyncSpawn SdsThreadRequest.process(request, addr rm) + let fireRes = ctx.reqReceivedSignal.fireSync() if fireRes.isErr(): error "could not fireSync back to requester thread", error = fireRes.error - ## Handle the request - asyncSpawn SdsThreadRequest.process(request, addr rm) - proc run(ctx: ptr SdsContext) {.thread.} = ## Launch sds worker waitFor runSds(ctx)