Add Linked constructor with stream parameter

dykov · dykov · commit d66ffc9382dd · 2021-05-27T22:03:03.000+03:00
diff --git a/src/main/java/io/github/dgroup/enumerable4j/Enumerable.java b/src/main/java/io/github/dgroup/enumerable4j/Enumerable.java
@@ -32,7 +32,6 @@
 import java.util.function.Consumer;
 import java.util.function.Function;
 import java.util.function.Predicate;
-import java.util.stream.Collectors;
 
 /**
  * The iterable with primitive operations witch simplify typical actions like count, map, etc.
@@ -93,7 +92,7 @@ default boolean none(Predicate<X> first, Predicate<X>... other) {
      */
     default Enumerable<X> select(Predicate<X> first, Predicate<X>... other) {
         return new Linked<>(
-            this.stream().filter(new Joined<>(first, other)).collect(Collectors.toList())
+            this.stream().filter(new Joined<>(first, other))
         );
     }
 
@@ -117,7 +116,7 @@ default Enumerable<X> reject(Predicate<X> first, Predicate<X>... other) {
                 }
             }
         }
-        return new Linked<>(this.stream().filter(prd).collect(Collectors.toList()));
+        return new Linked<>(this.stream().filter(prd));
     }
 
     /**
@@ -157,9 +156,7 @@ default <Y> Enumerable<Y> map(Function<? super X, ? extends Y> fnc) {
         if (fnc == null) {
             out = new Empty<>();
         } else {
-            out = new Linked<>(
-                this.stream().map(fnc).collect(Collectors.toList())
-            );
+            out = new Linked<>(this.stream().map(fnc));
         }
         return out;
     }
@@ -308,9 +305,7 @@ default Enumerable<X> take(long num) {
         } else if (num == 0) {
             out = new Empty<>();
         } else {
-            out = new Linked<>(
-                this.stream().limit(num).collect(Collectors.toList())
-            );
+            out = new Linked<>(this.stream().limit(num));
         }
         return out;
     }
@@ -329,9 +324,7 @@ default Enumerable<X> drop(long num) {
         } else if (num == 0) {
             out = this;
         } else {
-            out = new Linked<>(
-                this.stream().skip(num).collect(Collectors.toList())
-            );
+            out = new Linked<>(this.stream().skip(num));
         }
         return out;
     }
diff --git a/src/main/java/io/github/dgroup/enumerable4j/Linked.java b/src/main/java/io/github/dgroup/enumerable4j/Linked.java
@@ -23,6 +23,8 @@
  */
 package io.github.dgroup.enumerable4j;
 
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
 import org.cactoos.list.ListEnvelope;
 import org.cactoos.list.ListOf;
 
@@ -50,4 +52,12 @@ public Linked(final X... src) {
     public Linked(final Iterable<X> src) {
         super(new ListOf<>(src));
     }
+
+    /**
+     * Ctor.
+     * @param stream The stream of source items.
+     */
+    public Linked(final Stream<X> stream) {
+        super(stream.collect(Collectors.toList()));
+    }
 }

Original file line number	Diff line number	Diff line change
`@@ -32,7 +32,6 @@`
`32`	`32`	`import java.util.function.Consumer;`
`33`	`33`	`import java.util.function.Function;`
`34`	`34`	`import java.util.function.Predicate;`
`35`		`-import java.util.stream.Collectors;`
`36`	`35`
`37`	`36`	`/**`
`38`	`37`	`* The iterable with primitive operations witch simplify typical actions like count, map, etc.`
`@@ -93,7 +92,7 @@ default boolean none(Predicate<X> first, Predicate<X>... other) {`
`93`	`92`	`*/`
`94`	`93`	`default Enumerable<X> select(Predicate<X> first, Predicate<X>... other) {`
`95`	`94`	`return new Linked<>(`
`96`		`- this.stream().filter(new Joined<>(first, other)).collect(Collectors.toList())`
	`95`	`+ this.stream().filter(new Joined<>(first, other))`
`97`	`96`	`);`
`98`	`97`	`}`
`99`	`98`
`@@ -117,7 +116,7 @@ default Enumerable<X> reject(Predicate<X> first, Predicate<X>... other) {`
`117`	`116`	`}`
`118`	`117`	`}`
`119`	`118`	`}`
`120`		`- return new Linked<>(this.stream().filter(prd).collect(Collectors.toList()));`
	`119`	`+ return new Linked<>(this.stream().filter(prd));`
`121`	`120`	`}`
`122`	`121`
`123`	`122`	`/**`
`@@ -157,9 +156,7 @@ default <Y> Enumerable<Y> map(Function<? super X, ? extends Y> fnc) {`
`157`	`156`	`if (fnc == null) {`
`158`	`157`	`out = new Empty<>();`
`159`	`158`	`} else {`
`160`		`- out = new Linked<>(`
`161`		`- this.stream().map(fnc).collect(Collectors.toList())`
`162`		`- );`
	`159`	`+ out = new Linked<>(this.stream().map(fnc));`
`163`	`160`	`}`
`164`	`161`	`return out;`
`165`	`162`	`}`
`@@ -308,9 +305,7 @@ default Enumerable<X> take(long num) {`
`308`	`305`	`} else if (num == 0) {`
`309`	`306`	`out = new Empty<>();`
`310`	`307`	`} else {`
`311`		`- out = new Linked<>(`
`312`		`- this.stream().limit(num).collect(Collectors.toList())`
`313`		`- );`
	`308`	`+ out = new Linked<>(this.stream().limit(num));`
`314`	`309`	`}`
`315`	`310`	`return out;`
`316`	`311`	`}`
`@@ -329,9 +324,7 @@ default Enumerable<X> drop(long num) {`
`329`	`324`	`} else if (num == 0) {`
`330`	`325`	`out = this;`
`331`	`326`	`} else {`
`332`		`- out = new Linked<>(`
`333`		`- this.stream().skip(num).collect(Collectors.toList())`
`334`		`- );`
	`327`	`+ out = new Linked<>(this.stream().skip(num));`
`335`	`328`	`}`
`336`	`329`	`return out;`
`337`	`330`	`}`