Use spinners

shikokuchuo · Nov 30, 2023 · b336368 · b336368
1 parent e2cdeb9
commit b336368
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/tests/backlog/test-seconds_idle.R b/tests/backlog/test-seconds_idle.R
@@ -8,23 +8,25 @@ controller$start()
 names <- character(0L)
 index <- 0L
 n_tasks <- 60000L
+spinner <- cli::make_spinner()
 system.time(
   while (index < n_tasks || !(controller$empty())) {
     if (index < n_tasks) {
       index <- index + 1L
-      # cat("submit", index, "\n") # nolint
+      spinner$spin()
       controller$push(
         name = as.character(index),
         command = Sys.sleep(0.005)
       )
     }
     out <- controller$pop()
     if (!is.null(out)) {
-      # cat("collect", out$name, "\n") # nolint
+      spinner$spin()
       names[[length(names) + 1L]] <- out$name
     }
   }
 )
+spinner$finish()
 testthat::expect_equal(sort(as.integer(names)), seq_len(n_tasks))
 controller$launcher$workers$launched <- FALSE
 controller$launcher$tally()

diff --git a/tests/backlog/test-tasks_max.R b/tests/backlog/test-tasks_max.R
@@ -8,23 +8,25 @@ controller$start()
 names <- character(0L)
 index <- 0L
 n_tasks <- 60000L
+spinner <- cli::make_spinner()
 system.time(
   while (index < n_tasks || !(controller$empty())) {
     if (index < n_tasks) {
       index <- index + 1L
-      # cat("submit", index, "\n") # nolint
+      spinner$spin()
       controller$push(
         name = as.character(index),
         command = TRUE
       )
     }
     out <- controller$pop()
     if (!is.null(out)) {
-      # cat("collect", out$name, "\n") # nolint
+      spinner$spin()
       names[[length(names) + 1L]] <- out$name
     }
   }
 )
+spinner$finish()
 testthat::expect_equal(sort(as.integer(names)), seq_len(n_tasks))
 controller$launcher$workers$launched <- FALSE
 controller$launcher$tally()