tests/testthat/test-each.R

In gaborcsardi/async: Asynchronous Computation and 'I/O'

test_that("each", {

  do <- async(function() {
    done <- character()
    dx <- when_all(
      .list = lapply(letters[1:10], function(x) {
        force(x)
        delay(1/1000)$then(function(value) done <<- c(done, x))
      })
    )$
    then(function(value) expect_identical(sort(done), sort(letters[1:10])))
  })
  synchronise(do())
})