Skip to content

Commit ba2df25

Browse files
committed
polish
1 parent dca8fde commit ba2df25

File tree

3 files changed

+8
-2
lines changed

3 files changed

+8
-2
lines changed

client/src/main/java/io/split/engine/evaluator/EvaluatorImp.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,7 @@ private TreatmentLabelAndChangeNumber getTreatment(String matchingKey, String bu
117117

118118
for (ParsedCondition parsedCondition : parsedSplit.parsedConditions()) {
119119

120-
if (!inRollout && parsedCondition.conditionType() == ConditionType.ROLLOUT) {
120+
if (checkRollout(inRollout, parsedCondition)) {
121121

122122
if (parsedSplit.trafficAllocation() < 100) {
123123
// if the traffic allocation is 100%, no need to do anything special.
@@ -159,6 +159,10 @@ private TreatmentLabelAndChangeNumber getTreatment(String matchingKey, String bu
159159
}
160160
}
161161

162+
private boolean checkRollout(boolean inRollout, ParsedCondition parsedCondition) {
163+
return (!inRollout && parsedCondition.conditionType() == ConditionType.ROLLOUT);
164+
}
165+
162166
private String getBucketingKey(String bucketingKey, String matchingKey) {
163167
return (bucketingKey == null) ? matchingKey : bucketingKey;
164168
}

client/src/test/java/io/split/client/SplitClientIntegrationTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -528,7 +528,7 @@ public void splitClientMultiFactory() throws Exception {
528528
.until(() -> "on_whitelist".equals(client2.getTreatment("admin", "push_test")));
529529

530530
Awaitility.await()
531-
.atMost(50L, TimeUnit.SECONDS)
531+
.atMost(100L, TimeUnit.SECONDS)
532532
.until(() -> "on_whitelist".equals(client3.getTreatment("admin", "push_test")));
533533

534534
Awaitility.await()

client/src/test/java/io/split/engine/experiments/SplitParserTest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -100,6 +100,7 @@ public void works() {
100100
compareParsed(actual, expected);
101101
assertTrue(expected.hashCode() != 0);
102102
assertTrue(expected.equals(expected));
103+
Assert.assertEquals(expected.toString(), actual.toString());
103104
}
104105

105106
@Test
@@ -730,6 +731,7 @@ private void compareParsed(ParsedSplit actual, ParsedSplit expected) {
730731
Assert.assertEquals(actual.configurations(), expected.configurations());
731732
Assert.assertEquals(actual.prerequisitesMatcher().toString(), expected.prerequisitesMatcher().toString());
732733
}
734+
733735
private Split makeSplit(String name, int seed, List<Condition> conditions, long changeNumber) {
734736
return makeSplit(name, seed, conditions, changeNumber, null);
735737
}

0 commit comments

Comments
 (0)