File tree Expand file tree Collapse file tree 1 file changed +8
-13
lines changed
rsocket-core/src/test/java/io/rsocket/core Expand file tree Collapse file tree 1 file changed +8
-13
lines changed Original file line number Diff line number Diff line change @@ -314,19 +314,14 @@ public String get() {
314
314
315
315
Assertions .assertThat (expired ).isEmpty ();
316
316
317
- try {
318
-
319
- RaceTestUtils .race (
320
- () ->
321
- Assertions .assertThat (reconnectMono .block ())
322
- .matches (
323
- (v ) ->
324
- v .equals ("value_to_not_expire" + index )
325
- || v .equals ("value_to_expire" + index )),
326
- reconnectMono ::invalidate );
327
- } catch (Throwable t ) {
328
- t .printStackTrace ();
329
- }
317
+ RaceTestUtils .race (
318
+ () ->
319
+ Assertions .assertThat (reconnectMono .block ())
320
+ .matches (
321
+ (v ) ->
322
+ v .equals ("value_to_not_expire" + index )
323
+ || v .equals ("value_to_expire" + index )),
324
+ reconnectMono ::invalidate );
330
325
331
326
subscriber .assertTerminated ();
332
327
You can’t perform that action at this time.
0 commit comments