tests/testthat/test-poll3.R

In processx: Execute and Control System Processes

test_that("poll connection", {
  px <- get_tool("px")
  p <- process$new(px, c("sleep", ".5", "outln", "foobar"))
  on.exit(p$kill())

  ## Timeout
  expect_equal(p$poll_io(0), c(output = "nopipe", error = "nopipe",
                               process = "timeout"))

  p$wait()
  expect_equal(p$poll_io(-1), c(output = "nopipe", error = "nopipe",
                                process = "ready"))

  p$kill(close_connections = FALSE)
  expect_equal(p$poll_io(-1), c(output = "nopipe", error = "nopipe",
                                process = "ready"))

  close(p$get_poll_connection())
  expect_equal(p$poll_io(-1), c(output = "nopipe", error = "nopipe",
                                process = "closed"))
})

test_that("poll connection + stdout", {

  px <- get_tool("px")
  p1 <- process$new(px, c("outln", "foobar"), stdout = "|")
  on.exit(p1$kill(), add = TRUE)

  expect_false(p1$has_poll_connection())

  p2 <- process$new(px, c("sleep", "0.5", "outln", "foobar"), stdout = "|",
                   poll_connection = TRUE)
  on.exit(p2$kill(), add = TRUE)

  expect_equal(p2$poll_io(0), c(output = "timeout", error = "nopipe",
                                process = "timeout"))

  pr <- p2$poll_io(-1)
  expect_true("ready" %in% pr)
})

test_that("poll connection + stderr", {

  px <- get_tool("px")
  p1 <- process$new(px, c("errln", "foobar"), stderr = "|")
  on.exit(p1$kill(), add = TRUE)

  expect_false(p1$has_poll_connection())

  p2 <- process$new(px, c("sleep", "0.5", "errln", "foobar"), stderr = "|",
                   poll_connection = TRUE)
  on.exit(p2$kill(), add = TRUE)

  expect_equal(p2$poll_io(0), c(output = "nopipe", error = "timeout",
                                process = "timeout"))

})