tests/bpiterate.R

In HenrikBengtsson/BiocParallel.FutureParam: A BiocParallelParam Class for Futures

source("incl/start.R")
strategies <- all_strategies(excl = "multiprocess")

message("*** bpiterate() w/ FutureParam ...")

## Factory creating an iterator function
countIterator <- function(max) {
  local({
    count <- 0L
    function() {
      if (count == max) return(NULL)
      count <<- count + 1L
      count
    }
  })
} ## countIterator()


for (strategy in strategies) {
  message(sprintf("- plan('%s') ...", strategy))
  plan(strategy)

  message("  - sqrt()")
  max <- 5L
  expected <- lapply(1:max, FUN = sqrt)
  ITER <- countIterator(max)
  current <- bpiterate(ITER, FUN = sqrt)
  stopifnot(identical(expected, current))

  message(sprintf("- plan('%s') ... DONE", strategy))
} ## for (strategy ...)

message("*** bpiterate() w/ FutureParam ... DONE")

source("incl/end.R")