File tree Expand file tree Collapse file tree 1 file changed +3
-6
lines changed
aeron-system-tests/src/test/java/io/aeron Expand file tree Collapse file tree 1 file changed +3
-6
lines changed Original file line number Diff line number Diff line change 41
41
import java .util .concurrent .atomic .AtomicInteger ;
42
42
43
43
import static java .util .Arrays .asList ;
44
- import static org .hamcrest .MatcherAssert .*;
45
- import static org .hamcrest .Matchers .*;
46
- import static org .junit .jupiter .api .Assertions .assertEquals ;
47
44
import static org .junit .jupiter .api .Assertions .assertFalse ;
48
45
import static org .junit .jupiter .api .Assertions .assertTrue ;
49
46
@@ -223,9 +220,10 @@ void shouldRejoinAfterResting(final String channel)
223
220
aeron .conductorAgentInvoker ().invoke ();
224
221
}
225
222
223
+ final Image tetheredImage = tetheredSub .imageAtIndex (0 );
226
224
final Image untetheredImage = untetheredSub .imageAtIndex (0 );
227
- assertThat (untetheredImage .position (), lessThan ( publication .position ()));
228
- while ( untetheredImage .position () < publication .position ())
225
+ while (untetheredImage .position () < publication .position () ||
226
+ tetheredImage .position () < publication .position ())
229
227
{
230
228
int fragments = 0 ;
231
229
fragments += tetheredSub .poll (fragmentHandler , FRAGMENT_COUNT_LIMIT );
@@ -236,7 +234,6 @@ void shouldRejoinAfterResting(final String channel)
236
234
aeron .conductorAgentInvoker ().invoke ();
237
235
}
238
236
}
239
- assertEquals (publication .position (), tetheredSub .imageAtIndex (0 ).position ());
240
237
}
241
238
}
242
239
}
You can’t perform that action at this time.
0 commit comments