Remove unneccessary use of IntStream

Author: Sanne

hibernate-reactive-core/src/main/java/org/hibernate/reactive/loader/ReactiveResultSetProcessor.java

@@ -34,7 +34,6 @@
 import java.sql.SQLException;
 import java.util.List;
 import java.util.concurrent.CompletionStage;
-import java.util.stream.IntStream;
 
 import static org.hibernate.reactive.util.impl.CompletionStages.completedFuture;
 
@@ -80,13 +79,16 @@ default CompletionStage<Void> initializeEntity(
 		);
 
 		final Object[] hydratedState = entityEntry.getLoadedState();
-		return CompletionStages.loopWithoutTrampoline(
-				IntStream.range( 0, hydratedState.length )
-						.filter( i-> hydratedState[ i ] instanceof CompletionStage ),
-				i -> ( (CompletionStage<Object>) hydratedState[ i ] )
-						.thenAccept( initializedEntity -> hydratedState[ i ] = initializedEntity )
-		)
-		.thenAccept(
+		CompletionStage<Void> loop = CompletionStages.voidFuture();
+		for ( int i = 0; i < hydratedState.length; i++ ) {
+			final Object o = hydratedState[i];
+			if ( o instanceof CompletionStage ) {
+				final CompletionStage<?> c = (CompletionStage) o;
+				final int currentIndex = i;
+				loop = loop.thenCompose( v -> c.thenAccept( initializedEntity -> hydratedState[ currentIndex ] = initializedEntity ) );
+			}
+		}
+		return loop.thenAccept(
 				v -> TwoPhaseLoad.initializeEntityFromEntityEntryLoadedState(
 						entity,
 						entityEntry,

hibernate-reactive-core/src/main/java/org/hibernate/reactive/util/impl/CompletionStages.java

@@ -234,13 +234,6 @@ public static CompletionStage<Void> applyToAll(Function<Object, CompletionStage<
 		}
 	}
 
-	/**
-	 * Same as {@link #loop(Stream, Function)} but doesn't use the trampoline pattern
-	 */
-	public static CompletionStage<Void> loopWithoutTrampoline(IntStream stream, Function<Integer,CompletionStage<?>> consumer) {
-		return loopWithoutTrampoline( stream.iterator(), consumer );
-	}
-
 	/**
 	 * Same as {@link #loop(Iterator, Function)} but doesn't use the trampoline pattern
 	 */

hibernate-reactive-core/src/test/java/org/hibernate/reactive/CompletionStagesTest.java

@@ -111,15 +111,6 @@ public void testLoopOnIntStream(TestContext context) {
 		);
 	}
 
-	@Test
-	public void testLoopOnIntStreamWithoutTrampoline(TestContext context) {
-		test( context, loopWithoutTrampoline(
-				IntStream.range( 0, entries.length ),
-				index -> completedFuture( looped.add( entries[index] ) )
-			  ).thenAccept( v -> assertThat( looped ).containsExactly( entries ) )
-		);
-	}
-
 	@Test
 	public void testLoopWithIteratorWithoutTrampoline(TestContext context) {
 		test( context, loopWithoutTrampoline(