Remove coerceFuture(); not really needed

Author: HenrikBengtsson

NAMESPACE

@@ -9,7 +9,6 @@ S3method(as.FutureGlobals,list)
 S3method(as.character,FutureResult)
 S3method(as.raster,Mandelbrot)
 S3method(c,FutureGlobals)
-S3method(coerceFuture,FutureBackend)
 S3method(futures,environment)
 S3method(futures,list)
 S3method(futures,listenv)

R/backend_api-ClusterFutureBackend-class.R

@@ -33,7 +33,7 @@ ClusterFutureBackend <- function(workers = availableWorkers(), persistent = FALS
   stop_if_not(length(workers) > 0)
 
   core <- FutureBackend(workers = workers, persistent = persistent, ...)
-  core$futureClasses <- c("ClusterFuture", "Future")
+  core[["futureClasses"]] <- c("ClusterFuture", core[["futureClasses"]])
   core <- structure(core, class = c("ClusterFutureBackend", "FutureBackend", class(core)))
   core
 }
@@ -53,7 +53,7 @@ launchFuture.ClusterFutureBackend <- function(backend, future, ...) {
     workers = backend[["workers"]]
   )
   future <- do.call(as_ClusterFuture, args = args)
-  future <- coerceFuture(backend, future)
+  class(future) <- backend[["futureClasses"]]
 
   ## Next available cluster node
   t_start <- Sys.time()
@@ -195,7 +195,7 @@ MultisessionFutureBackend <- function(workers = availableCores(), ...) {
   }
 
   core <- ClusterFutureBackend(workers = workers, ...)
-  core$futureClasses <- c("MultisessionFuture", core$futureClasses)
+  core[["futureClasses"]] <- c("MultisessionFuture", core[["futureClasses"]])
   core <- structure(core, class = c("MultisessionFutureBackend", class(core)))
   core
 }

R/backend_api-FutureBackend-class.R

@@ -17,21 +17,12 @@ FutureBackend <- function(...) {
     core[[name]] <- args[[name]]
   }
 
-  core$futureClasses <- c("FutureBackend")
+  core[["futureClasses"]] <- c("FutureBackend")
   core <- structure(core, class = c("FutureBackend", class(core)))
+  core
 }
 
 
-coerceFuture <- function(backend, future, ...) {
-  UseMethod("coerceFuture")
-}
-
-#' @export
-coerceFuture.FutureBackend <- function(backend, future, ...) {
-  class(future) <- unique(c(backend$futureClasses, class(future)))
-  future
-}
-
 
 #' `launchFuture()` launches a future on the backend.
 #'

R/backend_api-MulticoreFutureBackend-class.R

@@ -27,7 +27,7 @@ MulticoreFutureBackend <- function(workers = availableCores(constraints = "multi
   }
 
   core <- FutureBackend(workers = workers, ...)
-  core$futureClasses <- c("MulticoreFuture", "Future")
+  core[["futureClasses"]] <- c("MulticoreFuture", core[["futureClasses"]])
   core <- structure(core, class = c("MulticoreFutureBackend", "FutureBackend", class(core)))
   core
 }
@@ -49,7 +49,7 @@ launchFuture.MulticoreFutureBackend <- function(backend, future, ...) {
 
   mcparallel <- importParallel("mcparallel")
 
-  future <- coerceFuture(backend, future)
+  class(future) <- backend[["futureClasses"]]
 
   data <- getFutureData(future, debug = debug)
 

R/backend_api-MultisessionFutureBackend-class.R

@@ -26,7 +26,7 @@ MultisessionFutureBackend <- function(workers = availableCores(), ...) {
   }
 
   core <- ClusterFutureBackend(workers = workers, ...)
-  core$futureClasses <- c("MultisessionFuture", core$futureClasses)
+  core[["futureClasses"]] <- c("MultisessionFuture", core[["futureClasses"]])
   core <- structure(core, class = c("MultisessionFutureBackend", class(core)))
   core
 }

R/backend_api-SequentialFutureBackend-class.R

@@ -10,7 +10,7 @@
 #' @export
 SequentialFutureBackend <- function(...) {
   core <- FutureBackend(...)
-  core$futureClasses <- c("SequentialFuture", "UniprocessFuture", core$futureClasses)
+  core[["futureClasses"]] <- c("SequentialFuture", "UniprocessFuture", core[["futureClasses"]])
   core <- structure(core, class = c("SequentialFutureBackend", class(core)))
   core
 }
@@ -34,7 +34,7 @@ launchFuture.SequentialFutureBackend <- function(backend, future, ...) {
   ## also the one that evaluates/resolves/queries it.
   assertOwner(future)
 
-  future <- coerceFuture(backend, future)
+  class(future) <- backend[["futureClasses"]]
 
   ## Launch future
   future[["state"]] <- "running"
@@ -46,7 +46,7 @@ launchFuture.SequentialFutureBackend <- function(backend, future, ...) {
   split <- backend[["split"]]
   if (!is.null(split)) data$capture$split <- split
   earlySignal <- backend[["earlySignal"]]
-  if (!is.null(earlySignal)) future$earlySignal <- earlySignal
+  if (!is.null(earlySignal)) future[["earlySignal"]] <- earlySignal
 
   future[["result"]] <- evalFuture(data)