Reactive a undone input steam when removed done input stream
@@ -126,11 +126,16 @@ final class DynamicWaitTimes {
streamList.remove(index);
statusList.remove(index);
index--;
- if (!streamList.isEmpty() && activeIfNeed()) {
+ if (!streamList.isEmpty()) {
+ if (index == -1){
+ index = 0;
+ }
// reactive all stream
+ if (activeIfNeed()) {
statusList.forEach(SingleStreamStatus::reset);
}
}
+ }
@Override
protected boolean allowAdjust() {
