tests/testthat/test.async_apply.R

In dipsaus: A Dipping Sauce for Data Analysis and Visualizations

context("async_*apply")

test_that("testing async_expr", {

  skip_on_cran()

  make_forked_clusters()
  re <- async_expr(1:10, { x })
  expect_equal(deparse_svec(unlist(re)), "1-10")

  re <- async_expr(1:10, {
    async({x})
    x + 1
  })
  expect_equal(deparse_svec(unlist(re)), "1-10")

  re <- async_expr(1:10, { async({ if (x > 1) x else NULL}) })
  expect_length(re, 10)
  expect_length(drop_nulls(re), 9)
})