完善测试用例，兼容空值调用

Author: taowater

src/main/java/com/taowater/ztream/Ztream.java

@@ -113,18 +113,6 @@ public static <T> Ztream<T> of(Stream<T> stream) {
         return Any.of(stream).map(Ztream::new).orElseGet(Ztream::empty);
     }
 
-    /**
-     * 如果流集合不为空，则执行以所有元素收集成List为入参的消费函数
-     *
-     * @param consumer 消费者
-     */
-    public <C extends Collection<T>> void ifNotEmpty(Consumer<C> consumer) {
-        C list = (C) this.toList();
-        if (EmptyUtil.isNotEmpty(list)) {
-            consumer.accept(list);
-        }
-    }
-
     /**
      * 遍历
      *
@@ -177,7 +165,10 @@ public <N> Ztream<N> convert(Class<N> clazz, BiConsumer<T, N> consumer) {
      */
     @SafeVarargs
     public final Ztream<T> append(T... values) {
-        return this.append(Ztream.of(values).toList());
+        if (EmptyUtil.isEmpty(values)) {
+            return this;
+        }
+        return append(Arrays.spliterator(values));
     }
 
     /**

src/main/java/com/taowater/ztream/op/Collect.java

@@ -2,6 +2,7 @@
 
 
 import com.taowater.taol.core.util.ConvertUtil;
+import com.taowater.ztream.Any;
 
 import java.util.*;
 import java.util.function.Function;
@@ -13,15 +14,15 @@
  * 收集操作
  *
  * @author Zhu56
- * @date 2022/11/13 19:12:35
+ * @since 0.0.1
  */
 public interface Collect<T> extends Stream<T> {
 
     /**
      * 收集为集合
      *
      * @param collectionFactory 集合工厂
-     * @return {@link C }
+     * @return 集合
      */
     default <C extends Collection<T>> C collect(Supplier<? extends C> collectionFactory) {
         return collect(Collectors.toCollection(collectionFactory));
@@ -32,28 +33,28 @@ default <C extends Collection<T>> C collect(Supplier<? extends C> collectionFact
      *
      * @param fun               属性
      * @param collectionFactory 集合工厂
-     * @return {@link C }
+     * @return 集合
      */
     default <V, C extends Collection<V>> C collect(Function<? super T, ? extends V> fun, Supplier<? extends C> collectionFactory) {
-        return this.map(fun).collect(Collectors.toCollection(collectionFactory));
+        return this.map(e -> Any.of(e).get(fun)).collect(Collectors.toCollection(collectionFactory));
     }
 
     /**
      * 转换类型收集
      *
      * @param clazz             clazz
      * @param collectionFactory 收集工厂
-     * @return {@link C }
+     * @return 集合
      */
     default <N, C extends Collection<N>> C collect(Class<N> clazz, Supplier<? extends C> collectionFactory) {
-        return this.map(e -> ConvertUtil.convert(e, clazz)).collect(Collectors.toCollection(collectionFactory));
+        return this.map(e -> Any.of(e).get(o -> ConvertUtil.convert(o, clazz))).collect(Collectors.toCollection(collectionFactory));
     }
 
     /**
      * 收集属性
      *
      * @param fun 属性
-     * @return {@link List }<{@link V }>
+     * @return 属性 ArrayList 集合
      */
     default <V> List<V> collect(Function<? super T, ? extends V> fun) {
         return this.collect(fun, ArrayList::new);
@@ -63,7 +64,7 @@ default <V> List<V> collect(Function<? super T, ? extends V> fun) {
      * 转换元素类型并收集
      *
      * @param clazz clazz
-     * @return {@link List}<{@link N}>
+     * @return 转换 ArrayList 集合
      */
     default <N> List<N> collect(Class<N> clazz) {
         return this.collect(clazz, ArrayList::new);
@@ -72,7 +73,7 @@ default <N> List<N> collect(Class<N> clazz) {
     /**
      * 收集为{@link ArrayList}
      *
-     * @return 集合
+     * @return ArrayList 集合
      */
     default List<T> toList() {
         return collect(Collectors.toList());
@@ -82,7 +83,7 @@ default List<T> toList() {
      * 收集某属性为list
      *
      * @param fun 函数
-     * @return {@link List }<{@link V }>
+     * @return 属性 ArrayList 集合
      */
     default <V> List<V> toList(Function<? super T, ? extends V> fun) {
         return this.collect(fun, ArrayList::new);
@@ -92,7 +93,7 @@ default <V> List<V> toList(Function<? super T, ? extends V> fun) {
      * 转换类型收集为list
      *
      * @param clazz clazz
-     * @return {@link List}<{@link N}>
+     * @return 转换 ArrayList 集合
      */
     default <N> List<N> toList(Class<N> clazz) {
         return this.collect(clazz, ArrayList::new);
@@ -101,7 +102,7 @@ default <N> List<N> toList(Class<N> clazz) {
     /**
      * 收集为{@link HashSet}
      *
-     * @return 集合
+     * @return HashSet 集合
      */
     default Set<T> toSet() {
         return collect(Collectors.toSet());
@@ -111,7 +112,7 @@ default Set<T> toSet() {
      * 收集某属性为set
      *
      * @param fun 函数
-     * @return {@link Set}<{@link V}>
+     * @return 属性 HashSet 集合
      */
     default <V> Set<V> toSet(Function<? super T, ? extends V> fun) {
         return this.collect(fun, HashSet::new);
@@ -120,8 +121,8 @@ default <V> Set<V> toSet(Function<? super T, ? extends V> fun) {
     /**
      * 转换类型收集set
      *
-     * @param clazz clazz
-     * @return {@link List}<{@link N}>
+     * @param clazz 类型
+     * @return 转换 HashSet 集合
      */
     default <N> Set<N> toSet(Class<N> clazz) {
         return this.collect(clazz, HashSet::new);

src/main/java/com/taowater/ztream/op/Filter.java

@@ -18,7 +18,7 @@
  * 过滤操作
  *
  * @author zhu56
- * @date 2024/07/13 00:33
+ * @see 0.0.3
  */
 public interface Filter<T, S extends IZtream<T, S>> extends IZtream<T, S> {
 
@@ -89,6 +89,7 @@ default <N extends Comparable<? super N>> S ge(Function<? super T, ? extends N>
      * @param rightValue 右值
      * @return 新流
      */
+    @SuppressWarnings("unchecked")
     default <N extends Comparable<? super N>> S between(Function<? super T, ? extends N> fun, N leftValue, N rightValue) {
         if (EmptyUtil.isAllEmpty(leftValue, rightValue)) {
             return wrap(this);
@@ -107,7 +108,7 @@ default <N extends Comparable<? super N>> S between(Function<? super T, ? extend
      */
     default S rightLike(Function<? super T, String> fun, String value) {
         return filter(e -> {
-            String str = fun.apply(e);
+            String str = Any.of(e).get(fun);
             if (EmptyUtil.isEmpty(str)) {
                 return EmptyUtil.isEmpty(value);
             }
@@ -136,7 +137,11 @@ default <V, C extends Collection<? extends V>> S in(Function<? super T, ? extend
      * @param values 值
      * @return 新流
      */
+    @SuppressWarnings("unchecked")
     default <V> S in(Function<? super T, ? extends V> fun, V... values) {
+        if (EmptyUtil.isEmpty(values)) {
+            return wrap(Stream.empty());
+        }
         return in(fun, Stream.of(values).collect(Collectors.toSet()));
     }
 
@@ -158,6 +163,7 @@ default <V, C extends Collection<? extends V>> S notIn(Function<? super T, ? ext
      * @param values 值
      * @return 新流
      */
+    @SuppressWarnings("unchecked")
     default <V> S notIn(Function<? super T, ? extends V> fun, V... values) {
         return notIn(fun, new HashSet<>(Arrays.asList(values)));
     }

src/main/java/com/taowater/ztream/op/GroupBy.java

@@ -16,7 +16,7 @@
  * 分组操作
  *
  * @author Zhu56
- * @date 2022/11/13 20:21:12
+ * @since 0.0.1
  */
 public interface GroupBy<T> extends Stream<T> {
 

src/main/java/com/taowater/ztream/op/Join.java

@@ -12,7 +12,7 @@
  * join操作
  *
  * @author Zhu56
- * @date 2022/11/13 19:12:35
+ * @since 0.0.1
  */
 public interface Join<T, S extends IZtream<T, S>> extends IZtream<T, S> {
 

src/main/java/com/taowater/ztream/op/Judge.java

@@ -14,7 +14,7 @@
  * 判断操作
  *
  * @author zhu56
- * @date 2024/07/15 00:42
+ * @date @since 0.1.13
  */
 public interface Judge<T, S extends IZtream<T, S>> extends IZtream<T, S> {
 

src/main/java/com/taowater/ztream/op/Math.java

@@ -15,8 +15,7 @@
  * 数学统计相关
  *
  * @author zhu56
- * @version 1.0
- * @date 2022/11/14 9:53
+ * @since 0.0.1
  */
 public interface Math<T> extends Stream<T> {
 

src/main/java/com/taowater/ztream/op/Sort.java

@@ -14,7 +14,7 @@
  * 排序操作
  *
  * @author zhu56
- * @date 2024/07/13 00:39
+ * @since 0.0.3
  */
 public interface Sort<T, S extends IZtream<T, S>> extends IZtream<T, S> {
 

src/main/java/com/taowater/ztream/op/ToMap.java

@@ -11,7 +11,7 @@
  * 映射操作
  *
  * @author Zhu56
- * @date 2022/11/13 20:21:12
+ * @since 0.0.1
  */
 public interface ToMap<T> extends Stream<T> {
 

src/test/java/com/taowater/ztream/TestClass.java

@@ -24,11 +24,9 @@ public static class Student extends Person {
 
     public static class Person {
         private String sex;
-
     }
 
     @Data
-    @EqualsAndHashCode(callSuper = true)
     public static class Teacher extends Person {
         private String name;
         private Long money;