R/000.import.R

In future: Unified Parallel and Distributed Processing in R for Everyone

import_from <- function(name, mode = "function", default = NULL, package) {
  ns <- getNamespace(package)
  if (exists(name, mode = mode, envir = ns, inherits = FALSE)) {
    get(name, mode = mode, envir = ns, inherits = FALSE)
  } else if (!is.null(default)) {
    default
  } else {
    stop(sprintf("No such '%s' %s: %s()", package, mode, name))
  }
}

import_parallelly <- function(...) {
  import_from(..., package = "parallelly")
}

import_parallel <- function(...) {
  import_from(..., package = "parallel")
}

import_parallel_fcn <- function(name, ...) {
  import_from(name, ..., default = function(...) {
    stop(sprintf("No such function: parallel:::%s()", name))
  }, package = "parallel")
}

## We are currently importing the following non-exported functions:
## * cluster futures:
##   - parallel:::defaultCluster()  ## non-critical / not really needed /
##                                  ## can be dropped in R (>= 3.5.0)
##   - parallel:::closeNode()       ## non-critical / 
##                                  ## can be dropped in R (>= 4.4.0)
##   - parallel:::sendCall()        ## run()
##   - parallel:::recvData()        ## can be dropped in R (>= 4.4.0)
## * multicore futures:
##   - parallel:::selectChildren()  ## resolved()
##   - parallel:::rmChild()         ## value()
## As well as the following ones (because they are not exported on Windows):
## * multicore futures:
##   - parallel::mcparallel()       ## run()
##   - parallel::mccollect()        ## value()
importParallel <- import_parallelly("importParallel")