Fix stream copying

mxprshn · mxprshn · commit 5d392ee440fa · 2024-08-29T15:28:13.000+03:00
diff --git a/approximations/src/main/java/generated/java/util/stream/BaseStreamImpl.java b/approximations/src/main/java/generated/java/util/stream/BaseStreamImpl.java
@@ -39,19 +39,19 @@ protected SymbolicList<Runnable> _getCloseHandlers() {
     }
 
     protected <T> StreamStubImpl<T> _copyToObjStream(T[] storage) {
-        return new StreamStubImpl<>(storage, _getCloseHandlers(), isParallel, linkedOrConsumed);
+        return new StreamStubImpl<>(storage, _getCloseHandlers(), isParallel, false);
     }
 
     protected IntStreamImpl _copyToIntStream(int[] storage) {
-        return new IntStreamImpl(storage, _getCloseHandlers(), isParallel, linkedOrConsumed);
+        return new IntStreamImpl(storage, _getCloseHandlers(), isParallel, false);
     }
 
     protected LongStreamImpl _copyToLongStream(long[] storage) {
-        return new LongStreamImpl(storage, _getCloseHandlers(), isParallel, linkedOrConsumed);
+        return new LongStreamImpl(storage, _getCloseHandlers(), isParallel, false);
     }
 
     protected DoubleStreamImpl _copyToDoubleStream(double[] storage) {
-        return new DoubleStreamImpl(storage, _getCloseHandlers(), isParallel, linkedOrConsumed);
+        return new DoubleStreamImpl(storage, _getCloseHandlers(), isParallel, false);
     }
 
     public void evaluate() {
diff --git a/approximations/src/main/java/generated/java/util/stream/DoubleStreamImpl.java b/approximations/src/main/java/generated/java/util/stream/DoubleStreamImpl.java
@@ -68,7 +68,7 @@ protected int _getLength() {
     }
 
     private DoubleStreamImpl _copy(double[] storage) {
-        return new DoubleStreamImpl(storage, _getCloseHandlers(), isParallel, linkedOrConsumed);
+        return new DoubleStreamImpl(storage, _getCloseHandlers(), isParallel, false);
     }
 
     private DoubleStreamImpl _copy() {
diff --git a/approximations/src/main/java/generated/java/util/stream/IntStreamImpl.java b/approximations/src/main/java/generated/java/util/stream/IntStreamImpl.java
@@ -66,7 +66,7 @@ protected int _getLength() {
     }
 
     private IntStreamImpl _copy(int[] storage) {
-        return new IntStreamImpl(storage, _getCloseHandlers(), isParallel, linkedOrConsumed);
+        return new IntStreamImpl(storage, _getCloseHandlers(), isParallel, false);
     }
 
     private IntStreamImpl _copy() {
diff --git a/approximations/src/main/java/generated/java/util/stream/LongStreamImpl.java b/approximations/src/main/java/generated/java/util/stream/LongStreamImpl.java
@@ -66,7 +66,7 @@ protected int _getLength() {
     }
 
     private LongStreamImpl _copy(long[] storage) {
-        return new LongStreamImpl(storage, _getCloseHandlers(), isParallel, linkedOrConsumed);
+        return new LongStreamImpl(storage, _getCloseHandlers(), isParallel, false);
     }
 
     private LongStreamImpl _copy() {
diff --git a/approximations/src/main/java/generated/java/util/stream/StreamStubImpl.java b/approximations/src/main/java/generated/java/util/stream/StreamStubImpl.java
@@ -78,7 +78,7 @@ protected int _getLength() {
     }
 
     private <T> StreamStubImpl<T> _copy(T[] storage) {
-        return new StreamStubImpl<>(storage, _getCloseHandlers(), isParallel, linkedOrConsumed);
+        return new StreamStubImpl<>(storage, _getCloseHandlers(), isParallel, false);
     }
 
     private StreamStubImpl<E> _copy() {

Original file line number	Diff line number	Diff line change
`@@ -39,19 +39,19 @@ protected SymbolicList<Runnable> _getCloseHandlers() {`
`39`	`39`	`}`
`40`	`40`
`41`	`41`	`protected <T> StreamStubImpl<T> _copyToObjStream(T[] storage) {`
`42`		`- return new StreamStubImpl<>(storage, _getCloseHandlers(), isParallel, linkedOrConsumed);`
	`42`	`+ return new StreamStubImpl<>(storage, _getCloseHandlers(), isParallel, false);`
`43`	`43`	`}`
`44`	`44`
`45`	`45`	`protected IntStreamImpl _copyToIntStream(int[] storage) {`
`46`		`- return new IntStreamImpl(storage, _getCloseHandlers(), isParallel, linkedOrConsumed);`
	`46`	`+ return new IntStreamImpl(storage, _getCloseHandlers(), isParallel, false);`
`47`	`47`	`}`
`48`	`48`
`49`	`49`	`protected LongStreamImpl _copyToLongStream(long[] storage) {`
`50`		`- return new LongStreamImpl(storage, _getCloseHandlers(), isParallel, linkedOrConsumed);`
	`50`	`+ return new LongStreamImpl(storage, _getCloseHandlers(), isParallel, false);`
`51`	`51`	`}`
`52`	`52`
`53`	`53`	`protected DoubleStreamImpl _copyToDoubleStream(double[] storage) {`
`54`		`- return new DoubleStreamImpl(storage, _getCloseHandlers(), isParallel, linkedOrConsumed);`
	`54`	`+ return new DoubleStreamImpl(storage, _getCloseHandlers(), isParallel, false);`
`55`	`55`	`}`
`56`	`56`
`57`	`57`	`public void evaluate() {`
Original file line number	Diff line number	Diff line change
`@@ -68,7 +68,7 @@ protected int _getLength() {`
`68`	`68`	`}`
`69`	`69`
`70`	`70`	`private DoubleStreamImpl _copy(double[] storage) {`
`71`		`- return new DoubleStreamImpl(storage, _getCloseHandlers(), isParallel, linkedOrConsumed);`
	`71`	`+ return new DoubleStreamImpl(storage, _getCloseHandlers(), isParallel, false);`
`72`	`72`	`}`
`73`	`73`
`74`	`74`	`private DoubleStreamImpl _copy() {`
Original file line number	Diff line number	Diff line change
`@@ -66,7 +66,7 @@ protected int _getLength() {`
`66`	`66`	`}`
`67`	`67`
`68`	`68`	`private IntStreamImpl _copy(int[] storage) {`
`69`		`- return new IntStreamImpl(storage, _getCloseHandlers(), isParallel, linkedOrConsumed);`
	`69`	`+ return new IntStreamImpl(storage, _getCloseHandlers(), isParallel, false);`
`70`	`70`	`}`
`71`	`71`
`72`	`72`	`private IntStreamImpl _copy() {`
Original file line number	Diff line number	Diff line change
`@@ -78,7 +78,7 @@ protected int _getLength() {`
`78`	`78`	`}`
`79`	`79`
`80`	`80`	`private <T> StreamStubImpl<T> _copy(T[] storage) {`
`81`		`- return new StreamStubImpl<>(storage, _getCloseHandlers(), isParallel, linkedOrConsumed);`
	`81`	`+ return new StreamStubImpl<>(storage, _getCloseHandlers(), isParallel, false);`
`82`	`82`	`}`
`83`	`83`
`84`	`84`	`private StreamStubImpl<E> _copy() {`