@@ -281,17 +281,17 @@ test_error(serial_config("custom", identity, "func2"), "must be a function or li
281281test_error(opt(rep , " wrong" ) <- cfg , " not supported" )
282282test_error(opt(rep , " serial" ) <- pairlist(a = 1L ), " not supported" )
283283
284- test_class(" recvAio" , cs <- request(req $ context , " test" , send_mode = " serial" , cv = cv , timeout = 500 ))
284+ test_class(" recvAio" , cs <- request(req $ context , " test" , send_mode = " serial" , cv = cv , timeout = 500 , id = 12345L ))
285285test_notnull(cs $ data )
286286test_type(" externalptr" , ctxn <- .context(rep ))
287- test_class(" recvAio" , cr <- recv_aio(ctxn , cv = cv , timeout = 500 ))
288- test_equal(call_aio(cr )$ data , " test " )
287+ test_class(" recvAio" , cr <- recv_aio(ctxn , mode = 8L , cv = cv , timeout = 500 ))
288+ test_equal(.read_header( call_aio(cr )$ data ), 12345L )
289289test_type(" integer" , cr $ aio )
290290test_type(" integer" , send(ctxn , TRUE , mode = 0L , block = FALSE ))
291291test_type(" externalptr" , ctxn <- .context(rep ))
292- test_class(" recvAio" , cs <- request(.context(req $ socket ), data = TRUE , cv = NA , id = 12345L ))
292+ test_class(" recvAio" , cs <- request(.context(req $ socket ), data = TRUE , cv = NA , id = TRUE ))
293293test_notnull(cs $ data )
294- test_equal(.read_header( recv(ctxn , mode = 8L , block = 500 )), 12345L )
294+ test_true( recv(ctxn , block = 500 ))
295295test_zero(send(ctxn , TRUE , mode = 1L , block = 500 ))
296296test_class(" recvAio" , cs <- request(.context(req $ socket ), data = TRUE , timeout = 5 , id = TRUE ))
297297test_zero(reap(ctxn ))
0 commit comments