Changing hasIncompleteVersionstamp to use iteration rather than stream processing

scottfines · scottfines · commit 5209a96e3426 · 2022-07-07T15:49:09.000-05:00
diff --git a/bindings/java/src/main/com/apple/foundationdb/tuple/Tuple.java b/bindings/java/src/main/com/apple/foundationdb/tuple/Tuple.java
@@ -86,7 +86,7 @@ private Tuple(Tuple original, Object newItem, boolean itemHasIncompleteVersionst
 
 	private Tuple(List<Object> elements) {
 		this.elements = elements;
-		incompleteVersionstamp = TupleUtil.hasIncompleteVersionstamp(elements.stream());
+		incompleteVersionstamp = TupleUtil.hasIncompleteVersionstamp(elements);
 	}
 
 	/**
diff --git a/bindings/java/src/main/com/apple/foundationdb/tuple/TupleUtil.java b/bindings/java/src/main/com/apple/foundationdb/tuple/TupleUtil.java
@@ -776,25 +776,44 @@ else if(item instanceof Tuple)
 		return packedSize;
 	}
 
-	static boolean hasIncompleteVersionstamp(Stream<?> items) {
-		return items.anyMatch(item -> {
-			if(item == null) {
-				return false;
-			}
-			else if(item instanceof Versionstamp) {
-				return !((Versionstamp) item).isComplete();
-			}
-			else if(item instanceof Tuple) {
-				return hasIncompleteVersionstamp(((Tuple) item).stream());
-			}
-			else if(item instanceof Collection<?>) {
-				return hasIncompleteVersionstamp(((Collection<?>) item).stream());
-			}
-			else {
-				return false;
-			}
-		});
-	}
+	static boolean hasIncompleteVersionstamp(Collection<?> items){
+		boolean isComplete = true;
+		for(Object itm: items){
+			if(itm instanceof Versionstamp){
+				isComplete = ((Versionstamp)itm).isComplete();
+			}else if(itm instanceof Tuple){
+				isComplete = hasIncompleteVersionstamp(((Tuple)itm).getItems());
+			}else if(itm instanceof Collection<?>){
+				isComplete = hasIncompleteVersionstamp((Collection<?>)itm);
+			}
+
+
+			if(!isComplete){
+				break;
+			}
+		}
+		return !isComplete;
+	}
+
+	// static boolean hasIncompleteVersionstamp(Stream<?> items) {
+	// 	return items.anyMatch(item -> {
+	// 		if(item == null) {
+	// 			return false;
+	// 		}
+	// 		else if(item instanceof Versionstamp) {
+	// 			return !((Versionstamp) item).isComplete();
+	// 		}
+	// 		else if(item instanceof Tuple) {
+	// 			return hasIncompleteVersionstamp(((Tuple) item).stream());
+	// 		}
+	// 		else if(item instanceof Collection<?>) {
+	// 			return hasIncompleteVersionstamp(((Collection<?>) item).stream());
+	// 		}
+	// 		else {
+	// 			return false;
+	// 		}
+	// 	});
+	// }
 
 	public static void main(String[] args) {
 		try {

Original file line number	Diff line number	Diff line change
`@@ -86,7 +86,7 @@ private Tuple(Tuple original, Object newItem, boolean itemHasIncompleteVersionst`
`86`	`86`
`87`	`87`	`private Tuple(List<Object> elements) {`
`88`	`88`	`this.elements = elements;`
`89`		`- incompleteVersionstamp = TupleUtil.hasIncompleteVersionstamp(elements.stream());`
	`89`	`+ incompleteVersionstamp = TupleUtil.hasIncompleteVersionstamp(elements);`
`90`	`90`	`}`
`91`	`91`
`92`	`92`	`/**`