tests/zmqSapply.tests.R

library(RzmqJobQueue)
zmqSapply("tcp://*:12346", list(n=as.list(1:10)), function(n) {
  Sys.sleep(runif(1, 0, 2))
  if (runif(1) < 0.5) stop("testing error handling")
  letters[1:n]
  })
wush978/RzmqJobQueue documentation built on May 4, 2019, 12:02 p.m.