From 709d8997d2ce0cb5b1c0d4e78978bcf79481aca2 Mon Sep 17 00:00:00 2001 From: Dewey Dunnington Date: Thu, 31 Aug 2023 09:47:50 -0300 Subject: [PATCH] Update r/adbcdrivermanager/tests/testthat/test-async.R MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: Kirill Müller --- r/adbcdrivermanager/tests/testthat/test-async.R | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/r/adbcdrivermanager/tests/testthat/test-async.R b/r/adbcdrivermanager/tests/testthat/test-async.R index 31995d3996..5416ae044d 100644 --- a/r/adbcdrivermanager/tests/testthat/test-async.R +++ b/r/adbcdrivermanager/tests/testthat/test-async.R @@ -17,10 +17,13 @@ test_that("aync array_stream$get_next", { stream <- nanoarrow::basic_array_stream(list(1:5)) + async_called <- FALSE queue <- adbc_array_stream_get_next_async(stream, function(array) { + async_called <<- TRUE expect_identical(nanoarrow::convert_array(array), 1:5) }) - Sys.sleep(0.5) + expect_false(async_called) expect_identical(adbc_callback_queue_run_pending(queue), 1) + expect_true(async_called) })