tests/testthat/test-annotation-message.R

In plumber2: Easy and Powerful Web Servers

test_that("serial message handler works", {
  pa <- api("annotations/serial_message.R")
  pa$test_message(fiery::fake_request("http://127.0.0.1:8080"), FALSE, "hi")
  expect_equal(pa$get_data("message"), "hi")
})

test_that("async message handler works", {
  pa <- api("annotations/async_message.R")
  pa$test_message(
    fiery::fake_request("http://127.0.0.1:8080"),
    FALSE,
    "async hi"
  )
  while (is.null(pa$get_data("async_message"))) {
    later::run_now()
    Sys.sleep(0.01)
  }
  expect_equal(pa$get_data("async_message"), "async hi")
})