update streams,add some filter methods about list and set

Author: ccoderJava

summer-java-core/src/main/java/com/dianpoint/summer/lang/Streams.java

@@ -1,6 +1,13 @@
 package com.dianpoint.summer.lang;
 
+import com.dianpoint.summer.utils.SetUtils;
+
+import java.util.Arrays;
+import java.util.LinkedHashSet;
+import java.util.List;
+import java.util.Set;
 import java.util.function.Predicate;
+import java.util.stream.Collectors;
 import java.util.stream.Stream;
 import java.util.stream.StreamSupport;
 
@@ -29,4 +36,35 @@ static <T> Stream<T> filterStream(T[] values, Predicate<? super T> predicate) {
     static <T, S extends Iterable<T>> Stream<T> filterStream(S values, Predicate<? super T> predicate) {
         return stream(values).filter(predicate);
     }
+
+    static <T> List<T> filterList(T[] values, Predicate<? super T> predicate) {
+        return filterList(Arrays.asList(values), predicate);
+    }
+
+    static <T, S extends Iterable<T>> List<T> filterList(S values, Predicate<? super T> predicate) {
+        return filterStream(values, predicate).collect(Collectors.toList());
+    }
+
+
+    static <T, S extends Iterable<T>> Set<T> filterSet(S values, Predicate<? super T> predicate) {
+        return filterStream(values, predicate).collect(LinkedHashSet::new, Set::add, Set::addAll);
+    }
+
+    static <T> Set<T> filterSet(T[] values, Predicate<T> predicate) {
+        return filterSet(Arrays.asList(values), predicate);
+    }
+
+
+    static <T, S extends Iterable<T>> S filterAll(S values, Predicate<? super T> predicate) {
+        boolean isSet = SetUtils.isSet(values);
+        if (isSet) {
+            return (S) filterSet(values, predicate);
+        }
+        return (S) filterList(values, predicate);
+    }
+
+
+    //filter逻辑操作
+
+
 }

summer-java-core/src/main/java/com/dianpoint/summer/utils/SetUtils.java

@@ -0,0 +1,33 @@
+package com.dianpoint.summer.utils;
+
+import java.util.Collections;
+import java.util.LinkedHashSet;
+import java.util.Set;
+
+public class SetUtils implements Utils {
+
+    protected static final float FIXED_LOAD_FACTOR = 1.00f;
+
+    public static boolean isSet(Iterable<?> elements) {
+        return elements instanceof Set;
+    }
+
+    public static <E> Set<E> of(E... elements) {
+    return ofSet(elements);
+    }
+
+    public static <E> Set<E> ofSet(E... elements) {
+        int size = elements == null ? 0 : elements.length;
+        if (size < 1) {
+            return Collections.emptySet();
+        } else if (size == 1) {
+            return Collections.singleton(elements[0]);
+        }
+
+        Set<E> set = new LinkedHashSet<>(size, FIXED_LOAD_FACTOR);
+        for (int i = 0; i < size; i++) {
+            set.add(elements[i]);
+        }
+        return Collections.unmodifiableSet(set);
+    }
+}