tests/incl/end.R

In doFuture: Use Foreach to Parallelize via the Future Framework

## Help shut down any stray PSOCK cluster futures
future::plan("sequential")

## Restore original state
options(oopts)
future::plan(oplan)
with(oldDoPar, foreach::setDoPar(fun=fun, data=data, info=info))

cons1 <- showConnections(all = FALSE)
diff <- all.equal(cons1, cons0)
if (!isTRUE(diff)) {
  cat("Connections before:\n")
  print(cons0)
  cat("Connections after:\n")
  print(cons1)
  cat("Difference:\n")
  print(diff)
  msg <- ("[INTERNAL] Detected stray connections after finishing test")
  if (nzchar(Sys.getenv("R_FUTURE_PLAN"))) {
    warning(msg)
  } else {
    stop(msg)
  }
}

rm(list = c(setdiff(ls(), ovars)))

print(sessionInfo())