@@ -112,11 +112,7 @@ public function testWriteClientLogin(Client $client, \stdClass $message)
112
112
$ message = $ this ->awaitMessage ($ client );
113
113
$ this ->assertEquals ('ClientLoginAck ' , $ message ->MsgType );
114
114
115
- try {
116
- $ message = $ this ->awaitMessage ($ client );
117
- } catch (\React \Promise \Timer \TimeoutException $ e ) {
118
- $ this ->markTestIncomplete ('Unhandled race condition, please retry ' );
119
- }
115
+ $ message = $ this ->awaitMessage ($ client );
120
116
$ this ->assertEquals ('SessionInit ' , $ message ->MsgType );
121
117
122
118
return $ message ;
@@ -290,11 +286,15 @@ public function testCreateClientWithInvalidAuthUrlRejects()
290
286
291
287
private function awaitMessage (Client $ client )
292
288
{
293
- return Block \await (new Promise (function ($ resolve , $ reject ) use ($ client ) {
294
- $ client ->once ('data ' , $ resolve );
289
+ try {
290
+ return Block \await (new Promise (function ($ resolve , $ reject ) use ($ client ) {
291
+ $ client ->once ('data ' , $ resolve );
295
292
296
- $ client ->once ('error ' , $ reject );
297
- $ client ->once ('close ' , $ reject );
298
- }), Loop::get (), 10.0 );
293
+ $ client ->once ('error ' , $ reject );
294
+ $ client ->once ('close ' , $ reject );
295
+ }), Loop::get (), 10.0 );
296
+ } catch (\React \Promise \Timer \TimeoutException $ e ) {
297
+ $ this ->markTestIncomplete ('Unhandled race condition, please retry ' );
298
+ }
299
299
}
300
300
}
0 commit comments