@@ -1,7 +1,7 @@

 Package: Streamer

 Type: Package

 Title: Enabling stream processing of large files

-Version: 1.3.6

+Version: 1.3.7

 Author: Martin Morgan, Nishant Gopalakrishnan

 Maintainer: Martin Morgan <mtmorgan@fhcrc.org>

 Description: Large data files can be difficult to work with in R,

@@ -118,6 +118,8 @@

 Team <-

     function(FUN, size=1L, mc.set.seed=TRUE, silent=TRUE, ...)

 {

+    if (.Platform$OS.type != "unix")

+        stop("'Team' not supported on platform '", .Platform$OS.type, "'")

     require(parallel)

     if (size < 1L)

         stop("'size' must be >= 1")

@@ -1,9 +1,10 @@

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

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

+    function(...) {}

 .onLoad <-

     function(libname, pkgname)

 {

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

+    if (.Platform$OS.type == "unix") {

         ## conditional export in Windows

         .mc_parallel <<- parallel::mcparallel

         .mc_collect <<- parallel::mccollect

@@ -108,12 +108,13 @@

 }

 \examples{

-team <- Team(function(x) { Sys.sleep(1); mean(x) }, size=5)

-s <- stream(Seq(to=50, length.out=5), team)

-system.time({

-    while(length(y <- yield(s)))

+if (.Platform$OS.type != "windows") {

+    team <- Team(function(x) { Sys.sleep(1); mean(x) }, size=5)

+    s <- stream(Seq(to=50, length.out=5), team)

+    system.time({while(length(y <- yield(s)))

         print(y)

-})

+    })

+}

 }

 \keyword{classes}