Add test of the, currently internal, capture_journals() function

futureverse · Jan 30, 2024 · d874af5 · d874af5
1 parent ef4d651
commit d874af5
Show file tree

Hide file tree

Showing 2 changed files with 28 additions and 1 deletion.
diff --git a/DESCRIPTION b/DESCRIPTION
@@ -1,5 +1,5 @@
 Package: future
-Version: 1.33.1-9002
+Version: 1.33.1-9003
 Title: Unified Parallel and Distributed Processing in R for Everyone
 Imports:
     digest,

diff --git a/tests/capture_journals.R b/tests/capture_journals.R
@@ -0,0 +1,27 @@
+source("incl/start.R")
+
+capture_journals <- future:::capture_journals
+
+message("*** capture_journals() ...")
+
+slow_fcn <- function(x) {
+  Sys.sleep(0.5 + 1/x)
+}
+
+plan(multisession, workers = 2)
+js <- capture_journals({
+  fs <- lapply(3:1, FUN = function(x) future(slow_fcn(x)))
+  vs <- value(fs)
+})
+print(js)
+stopifnot(
+  is.list(js),
+  all(vapply(js, FUN = is.data.frame, FUN.VALUE = NA))
+)
+
+## Shut down parallel workers
+plan(sequential)
+
+message("*** capture_journals() ... done")
+
+source("incl/end.R")