From 16a18a7d87face35fca3a62b51c8a301eec06129 Mon Sep 17 00:00:00 2001
From: wxm <115806199+youfanx@users.noreply.github.com>
Date: Fri, 26 Apr 2024 11:47:36 +0800
Subject: [PATCH] up

---
 rxlib/src/main/java/org/rx/bean/NEnum.java |  8 ++++++++
 rxlib/src/main/java/org/rx/core/Linq.java  | 16 ++++++++++++++++
 2 files changed, 24 insertions(+)

diff --git a/rxlib/src/main/java/org/rx/bean/NEnum.java b/rxlib/src/main/java/org/rx/bean/NEnum.java
index b3db6e0c..a202a102 100644
--- a/rxlib/src/main/java/org/rx/bean/NEnum.java
+++ b/rxlib/src/main/java/org/rx/bean/NEnum.java
@@ -3,6 +3,7 @@
 import lombok.NonNull;
 import lombok.SneakyThrows;
 import org.rx.core.Extends;
+import org.rx.exception.InvalidException;
 
 import java.io.Serializable;
 
@@ -10,11 +11,18 @@
 
 public interface NEnum<T extends Enum<T> & NEnum<T>> extends Serializable {
     static <T extends Enum<T> & NEnum<T>> T valueOf(@NonNull Class<T> type, int value) {
+        return valueOf(type, value, true);
+    }
+
+    static <T extends Enum<T> & NEnum<T>> T valueOf(@NonNull Class<T> type, int value, boolean throwOnEmpty) {
         for (T nEnum : type.getEnumConstants()) {
             if (nEnum.getValue() == value) {
                 return nEnum;
             }
         }
+        if (throwOnEmpty) {
+            throw new InvalidException("Enum {} not contains {}", type, value);
+        }
         return null;
     }
 
diff --git a/rxlib/src/main/java/org/rx/core/Linq.java b/rxlib/src/main/java/org/rx/core/Linq.java
index 73bf9201..c02d49d1 100644
--- a/rxlib/src/main/java/org/rx/core/Linq.java
+++ b/rxlib/src/main/java/org/rx/core/Linq.java
@@ -8,9 +8,12 @@
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.collections4.IteratorUtils;
+import org.apache.commons.collections4.ListUtils;
+import org.apache.commons.lang3.ArrayUtils;
 import org.rx.annotation.ErrorCode;
 import org.rx.bean.$;
 import org.rx.bean.Decimal;
+import org.rx.bean.Tuple;
 import org.rx.exception.ApplicationException;
 import org.rx.util.function.*;
 
@@ -299,6 +302,19 @@ public Linq<T> union(Iterable<T> set) {
         return Linq.from(CollectionUtils.union(this, set));
     }
 
+    //ListUtils.partition()
+    public Linq<List<T>> partition(int size) {
+        List<List<T>> n = newList();
+        List<T> a = toList();
+        int f = 0, t = 0;
+        while (f < a.size()) {
+            t = Math.min(t + size, a.size());
+            n.add(a.subList(f, t));
+            f = t;
+        }
+        return me(n);
+    }
+
     public Linq<T> orderByRand() {
         return me(stream().sorted(getComparator(p -> ThreadLocalRandom.current().nextInt(0, 100), false)));
     }