From 9c7c47e66a3dbf54b607671ac6e3c11cbb7d8d30 Mon Sep 17 00:00:00 2001 From: Jaremy Creechley Date: Mon, 25 Sep 2023 23:29:22 -0700 Subject: [PATCH] integrate setups --- datastore/threads/threadproxyds.nim | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/datastore/threads/threadproxyds.nim b/datastore/threads/threadproxyds.nim index 56f8490..9e5ce85 100644 --- a/datastore/threads/threadproxyds.nim +++ b/datastore/threads/threadproxyds.nim @@ -73,12 +73,12 @@ proc acquireSignal(): ?!ThreadSignalPtr = else: success signal.get() -template dispatchTask(self: ThreadDatastore, - signal: ThreadSignalPtr, - blk: untyped - ): auto = +template dispatchTask[T](self: ThreadDatastore, + signal: ThreadSignalPtr, + blk: untyped + ): auto = var - ctx {.inject.} = TaskCtx[SqliteDB, bool](signal: signal) + ctx {.inject.} = TaskCtx[SqliteDB, T](signal: signal) try: case self.backend.kind: of Sqlite: @@ -130,7 +130,7 @@ method has*(self: ThreadDatastore, return failure err let key = KeyId.new key.id() - dispatchTask(self, signal): + dispatchTask[bool](self, signal): self.tp.spawn hasTask(addr ctx, ds, key) proc deleteTask[DB](ctx: ptr TaskCtx, ds: DB; @@ -146,7 +146,7 @@ method delete*(self: ThreadDatastore, return failure err let key = KeyId.new key.id() - dispatchTask(self, signal): + dispatchTask[void](self, signal): self.tp.spawn deleteTask(addr ctx, ds, key) method delete*(self: ThreadDatastore,