@@ -281,17 +281,17 @@ test_error(serial_config("custom", identity, "func2"), "must be a function or li
281
281
test_error(opt(rep , " wrong" ) <- cfg , " not supported" )
282
282
test_error(opt(rep , " serial" ) <- pairlist(a = 1L ), " not supported" )
283
283
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 ))
285
285
test_notnull(cs $ data )
286
286
test_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 )
289
289
test_type(" integer" , cr $ aio )
290
290
test_type(" integer" , send(ctxn , TRUE , mode = 0L , block = FALSE ))
291
291
test_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 ))
293
293
test_notnull(cs $ data )
294
- test_equal(.read_header( recv(ctxn , mode = 8L , block = 500 )), 12345L )
294
+ test_true( recv(ctxn , block = 500 ))
295
295
test_zero(send(ctxn , TRUE , mode = 1L , block = 500 ))
296
296
test_class(" recvAio" , cs <- request(.context(req $ socket ), data = TRUE , timeout = 5 , id = TRUE ))
297
297
test_zero(reap(ctxn ))
0 commit comments