diff --git a/datastore/threads/threadproxyds.nim b/datastore/threads/threadproxyds.nim index 8c84fc7..dbe2554 100644 --- a/datastore/threads/threadproxyds.nim +++ b/datastore/threads/threadproxyds.nim @@ -286,6 +286,7 @@ method query*[BT](self: ThreadDatastore[BT], without signal =? acquireSignal(), err: return failure err let ctx = newTaskCtx(QResult, signal=signal) + echo "nextSignal:OPEN!" ctx[].nextSignal.init() try: