[wip] restore scheduled stop

2021-12-02 17:12:35 -06:00 · 2021-12-02 17:12:35 -06:00 · 1d94fc3b85
parent fc55073147
commit 1d94fc3b85
1 changed files with 1 additions and 1 deletions
--- a/experiments/task_runner_streams.nim
+++ b/experiments/task_runner_streams.nim
@ -112,7 +112,7 @@ proc main() {.async.} =
  runner.workers[experiment].worker.awaitTasks = false
  await runner.start
  server.start
-  # asyncSpawn runner.scheduleStop(10.seconds)
+  asyncSpawn runner.scheduleStop(10.seconds)

  while runner.running.load: poll()