From 6ddcc5d4f863fc3ed5c612ddf05aa83099e20139 Mon Sep 17 00:00:00 2001
From: Jaremy Creechley <creechley@gmail.com>
Date: Wed, 21 Feb 2024 19:51:43 -0700
Subject: [PATCH] initial setup

---
 tests/exCursor.nim  |  1 +
 tests/exFailure.nim | 31 +++++++++++++++++++++++++++++++
 2 files changed, 32 insertions(+)
 create mode 100644 tests/exCursor.nim
 create mode 100644 tests/exFailure.nim

diff --git a/tests/exCursor.nim b/tests/exCursor.nim
new file mode 100644
index 0000000..8b13789
--- /dev/null
+++ b/tests/exCursor.nim
@@ -0,0 +1 @@
+
diff --git a/tests/exFailure.nim b/tests/exFailure.nim
new file mode 100644
index 0000000..8cea4ac
--- /dev/null
+++ b/tests/exFailure.nim
@@ -0,0 +1,31 @@
+import std/os
+import std/sequtils
+
+import chronos
+import chronos/threadsync
+import chronos/unittest2/asynctests
+import taskpools
+
+import apatheia/queues
+
+proc worker(data: seq[char], queue: SignalQueue[int]) =
+  os.sleep(50)
+  echo "worker: ", data
+  discard queue.send(data.len())
+
+suite "async tests":
+
+  var tp = Taskpool.new(num_threads = 2) # Default to the number of hardware threads.
+  var queue = newSignalQueue[int]()
+
+  asyncTest "test":
+
+    ## init
+    var data = "hello world!".toSeq
+    tp.spawn worker(data, queue)
+
+    let res = await wait(queue).wait(1500.milliseconds)
+
+    check res.get() == 12
+
+