From 87db11ea656cbd0819c75d518d3b9e3c020a6aee Mon Sep 17 00:00:00 2001
From: Geoffrey Churchill <geoffrey.a.churchill@gmail.com>
Date: Sun, 31 Jul 2022 14:25:22 -0400
Subject: [PATCH] Improve `insertInStream`

New version works with infinite streams and has constant space/time complexity.
---
 .../com/baeldung/streams/StreamAddUnitTest.java    | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git a/core-java-modules/core-java-streams-2/src/test/java/com/baeldung/streams/StreamAddUnitTest.java b/core-java-modules/core-java-streams-2/src/test/java/com/baeldung/streams/StreamAddUnitTest.java
index 1fada26de5..e80a4e431b 100644
--- a/core-java-modules/core-java-streams-2/src/test/java/com/baeldung/streams/StreamAddUnitTest.java
+++ b/core-java-modules/core-java-streams-2/src/test/java/com/baeldung/streams/StreamAddUnitTest.java
@@ -2,9 +2,13 @@ package com.baeldung.streams;
 
 import org.junit.Test;
 
+import java.util.Iterator;
 import java.util.List;
+import java.util.Spliterator;
+import java.util.Spliterators;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
+import java.util.stream.StreamSupport;
 
 import static org.junit.Assert.assertEquals;
 
@@ -40,6 +44,16 @@ public class StreamAddUnitTest {
         assertEquals(resultList.get(3), (Double) 9.9);
     }
 
+    private static <T> Stream<T> insertInStream(Stream<T> stream, T elem, int index) {
+        final Spliterator<T> spliterator = stream.spliterator();
+        final Iterator<T> iterator = Spliterators.iterator(spliterator);
+        
+        return Stream.concat(Stream.concat(
+            Stream.generate(iterator::next).limit(index),
+            Stream.of(elem)),
+            StreamSupport.stream(spliterator, /* parallel= */ false));
+    }
+    
     private <T> Stream<T> insertInStream(Stream<T> stream, T elem, int index) {
         List<T> result = stream.collect(Collectors.toList());
         result.add(index, elem);