Fix printing parallel stdout w/ chunky event loop

Author: gaborcsardi

R/parallel.R

@@ -144,7 +144,7 @@ parallel_event_loop_smooth <- function(queue, reporters, test_dir) {
     updated <- FALSE
     for (x in msgs) {
       if (x$code == PROCESS_OUTPUT) {
-        lns <- paste0(x$path, ": ", x$message)
+        lns <- paste0("> ", x$path, ": ", x$message)
         cat("\n", file = stdout())
         base::writeLines(lns, stdout())
         next
@@ -184,6 +184,11 @@ parallel_event_loop_chunky <- function(queue, reporters, test_dir) {
   while (!queue$is_idle()) {
     msgs <- queue$poll(Inf)
     for (x in msgs) {
+      if (x$code == PROCESS_OUTPUT) {
+        lns <- paste0("> ", x$path, ": ", x$message)
+        base::writeLines(lns, stdout())
+        next
+      }
       if (x$code != PROCESS_MSG) {
         next
       }
@@ -210,10 +215,7 @@ parallel_event_loop_chunky <- function(queue, reporters, test_dir) {
 replay_events <- function(reporter, events) {
   snapshotter <- getOption("testthat.snapshotter")
   for (m in events) {
-    if (m$code == PROCESS_OUTPUT) {
-      lns <- paste0(m$path, ": ", m$message)
-      base::writeLines(lns, stdout())
-    } else if (m$type == "snapshotter") {
+    if (m$type == "snapshotter") {
       do.call(snapshotter[[m$cmd]], m$args)
     } else {
       do.call(reporter[[m$cmd]], m$args)

tests/testthat/test-describe.R

@@ -50,5 +50,6 @@ describe("describe", {
   it("should not be possible to access variables from other specs (2)", {
     expect_false(exists("some_test_var"))
   })
+  withr::local_options(width = 60)
   print(1:100)
 })