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() {
314314
315315 Assertions .assertThat (expired ).isEmpty ();
316316
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 );
330325
331326 subscriber .assertTerminated ();
332327
You can’t perform that action at this time.
0 commit comments