@@ -4,7 +4,8 @@ import(methods)

 importFrom(BiocGenerics, lapply, sapply)

-importFrom(parallel, mcparallel, mccollect)

+## only exported on unix

+## importFrom(parallel, mccollect, mcparallel)

 importFrom(graph, graphBAM)

@@ -23,7 +23,7 @@

         x$inputPipe <- y

         y$inUse <- TRUE

         if (is(x, "ParallelConnector")) {

-            x$.upstream <- mcparallel(quote({

+            x$.upstream <- .mc_parallel(quote({

                 while(TRUE) {

                     prime <- yield(y)

                     sendMaster(prime)

@@ -6,7 +6,7 @@

     results <- vector("list", length(jobs))

     t0 <- as.numeric(Sys.time(), units="secs") + timeout

     for (i in seq_along(jobs)) {

-        result <- mccollect(jobs[[i]], wait, timeout, intermediate)

+        result <- .mc_collect(jobs[[i]], wait, timeout, intermediate)

         if (is.null(result))

             results[i] <- list(NULL)

         else results[[i]] <- result[[1]]

@@ -60,7 +60,7 @@

               task[c("name", "result", "status")] <-

                   list(.id, value, "ERROR")

           } else {

-              task <- mcparallel(FUN(value), .id, mc.set.seed, silent)

+              task <- .mc_parallel(FUN(value), .id, mc.set.seed, silent)

               task$status <- "YIELD"

           }

           .self$tasks[[idx]] <- task

@@ -80,7 +80,7 @@

           results <- results[idx]

           nms <- base::names(results)

           tids <- match(nms, names())

-          parallel:::mckill(tasks[tids], 15)

+          .mc_kill(tasks[tids], 15)

           for (i in seq_along(nms)) {

               tid <- tids[i]

               task <- tasks[[tid]]

@@ -70,10 +70,10 @@ connect <-

         }

         if (is(right, "ParallelConnector")) {

-            right$.upstream <- mcparallel(quote({

+            right$.upstream <- .mc_parallel(quote({

                 while(TRUE) {

                     prime <- yield(left)

-                    parallel:::sendMaster(prime)

+                    .mc_sendMaster(prime)

                 }}))

         }

@@ -1,3 +1,18 @@

+.mc_parallel <- .mc_collect <- .mc_sendMaster <- .mc_kill <- NULL

+

+.onLoad <-

+    function(libname, pkgname)

+{

+    if (tools:::.OStype() == "unix") {

+        ## conditional export in Windows

+        .mc_parallel <<- parallel::mcparallel

+        .mc_collect <<- parallel::mccollect

+        ## non-exported

+        .mc_kill <<- parallel:::mckill

+        .mc_sendMaster <<- parallel:::sendMaster

+    }

+}

+

 .ppath <-

     function(tag, filepath)

 {

@@ -38,7 +38,6 @@

   \item{USE.NAMES}{See \code{?base::sapply} but note that names do not

     usually make sense for instances of class \code{Producer}.}

-  \item{.env}{For internal use}

 }

 \section{Methods}{