R/utils.R

In furrr: Apply Mapping Functions in Parallel using Futures

cat_line <- function(...) {
  cat(paste0(..., "\n", collapse = ""))
}


import_future <- function(name, default = NULL) {
  import_from(name, default = default, package = "future")
}

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

get_total_size <- function(x) {
  attr(x, "total_size", exact = TRUE)
}
set_total_size <- function(x, total_size) {
  attr(x, "total_size") <- total_size
  x
}