@@ -199,10 +199,11 @@ nanotesterr(req$opt("false", list()), "type")
199
199
200
200
nanotestaio(r <- recv_aio(rep , timeout = 500 ))
201
201
nanotestz(req $ send(" " , block = 500 ))
202
- p <- tryCatch(collect_pipe(rep ), error = function (e ) NULL )
203
- if (! is.null(p )) nanotestnano(p )
202
+ p <- tryCatch(collect_pipe(r ), error = function (e ) NULL )
204
203
nanotestp(p )
205
- nanotestz(send(rep , " " , block = 500 ))
204
+ if (! is.null(p )) nanotestnano(p )
205
+ nanotestaio(r <- send_aio(rep , " " , timeout = 500 ))
206
+ nanotesterr(collect_pipe(r ), " valid" )
206
207
nanotestnn(req $ recv())
207
208
208
209
nanotestnano(ctx <- context(rep ))
@@ -523,6 +524,7 @@ nanotesterr(send(fakestream, "test"), "valid")
523
524
nanotesterr(send_aio(fakestream , " test" ), " valid" )
524
525
nanotesterr(recv(fakestream ), " valid" )
525
526
nanotesterr(recv_aio(fakestream ), " valid" )
527
+ nanotesterr(collect_pipe(fakestream ), " valid" )
526
528
nanotesterr(opt(fakestream , name = " test" ) <- " test" , " valid" )
527
529
nanotesterr(opt(fakestream , name = " test" ), " valid" )
528
530
nanotesterr(close(fakestream ), " active Stream" )
0 commit comments