diff --git a/hutool-core/src/main/java/org/dromara/hutool/core/stream/EasyStream.java b/hutool-core/src/main/java/org/dromara/hutool/core/stream/EasyStream.java index 3c063c618..1e9128868 100644 --- a/hutool-core/src/main/java/org/dromara/hutool/core/stream/EasyStream.java +++ b/hutool-core/src/main/java/org/dromara/hutool/core/stream/EasyStream.java @@ -124,7 +124,7 @@ public class EasyStream extends AbstractEnhancedWrappedStream 元素类型 * @return 包含单个元素的串行流 */ @@ -136,9 +136,9 @@ public class EasyStream extends AbstractEnhancedWrappedStream 元素类型 + * @param 元素类型 * @return 包含指定元素的串行流 - * 从一个安全数组中创建流 + * 从一个安全数组中创建流 */ @SafeVarargs @SuppressWarnings("varargs") @@ -150,7 +150,7 @@ public class EasyStream extends AbstractEnhancedWrappedStream 元素类型 + * @param 元素类型 * @return 流 */ public static EasyStream of(final Iterable iterable) { @@ -162,22 +162,22 @@ public class EasyStream extends AbstractEnhancedWrappedStream 元素类型 + * @param 元素类型 * @return 流 */ public static EasyStream of(final Iterable iterable, final boolean parallel) { return Opt.ofNullable(iterable) - .map(Iterable::spliterator) - .map(spliterator -> StreamSupport.stream(spliterator, parallel)) - .map(EasyStream::new) - .orElseGet(EasyStream::empty); + .map(Iterable::spliterator) + .map(spliterator -> StreamSupport.stream(spliterator, parallel)) + .map(EasyStream::new) + .orElseGet(EasyStream::empty); } /** * 通过传入的{@link Stream}创建流,若输入对象为{@code null},则返回一个空的串行流 * * @param stream {@link Stream} - * @param 元素类型 + * @param 元素类型 * @return 流 */ public static EasyStream of(final Stream stream) { @@ -193,9 +193,9 @@ public class EasyStream extends AbstractEnhancedWrappedStream * - * @param 元素类型 + * @param 元素类型 * @param seed 初始值 - * @param f 用上一个元素作为参数执行并返回一个新的元素 + * @param f 用上一个元素作为参数执行并返回一个新的元素 * @return 无限有序流 */ public static EasyStream iterate(final T seed, final UnaryOperator f) { @@ -211,14 +211,14 @@ public class EasyStream extends AbstractEnhancedWrappedStream * - * @param 元素类型 - * @param seed 初始值 + * @param 元素类型 + * @param seed 初始值 * @param hasNext 条件值 - * @param next 用上一个元素作为参数执行并返回一个新的元素 + * @param next 用上一个元素作为参数执行并返回一个新的元素 * @return 无限有序流 */ public static EasyStream iterate(final T seed, final Predicate hasNext, - final UnaryOperator next) { + final UnaryOperator next) { Objects.requireNonNull(next); Objects.requireNonNull(hasNext); return new EasyStream<>(StreamUtil.iterate(seed, hasNext, next)); @@ -226,7 +226,7 @@ public class EasyStream extends AbstractEnhancedWrappedStream指定一个层级结构的根节点(通常是树或图), - * 然后获取包含根节点在内,根节点所有层级结构中的节点组成的流。
+ * 然后获取包含根节点在内,根节点所有层级结构中的节点组成的流。
* 该方法用于以平铺的方式对图或树节点进行访问,可以使用并行流提高效率。 * *

eg: @@ -239,19 +239,20 @@ public class EasyStream extends AbstractEnhancedWrappedStream * - * @param root 根节点 + * @param root 根节点 * @param discoverer 下一层级节点的获取方法 - * @param filter 节点过滤器,不匹配的节点与以其作为根节点的子树将将会被忽略 + * @param filter 节点过滤器,不匹配的节点与以其作为根节点的子树将将会被忽略 + * @param 对象类型 * @return 包含根节点在内,根节点所有层级结构中的节点组成的流 */ public static EasyStream iterateHierarchies( - T root, final Function> discoverer, Predicate filter) { + final T root, final Function> discoverer, final Predicate filter) { return of(StreamUtil.iterateHierarchies(root, discoverer, filter)); } /** *

指定一个层级结构的根节点(通常是树或图), - * 然后获取包含根节点在内,根节点所有层级结构中的节点组成的流。
+ * 然后获取包含根节点在内,根节点所有层级结构中的节点组成的流。
* 该方法用于以平铺的方式对图或树节点进行访问,可以使用并行流提高效率。 * *

eg: @@ -264,12 +265,13 @@ public class EasyStream extends AbstractEnhancedWrappedStream * - * @param root 根节点 + * @param root 根节点 * @param discoverer 下一层级节点的获取方法 + * @param 对象类型 * @return 包含根节点在内,根节点所有层级结构中的节点组成的流 */ public static EasyStream iterateHierarchies( - T root, final Function> discoverer) { + final T root, final Function> discoverer) { return of(StreamUtil.iterateHierarchies(root, discoverer)); } @@ -279,7 +281,7 @@ public class EasyStream extends AbstractEnhancedWrappedStream 元素类型 - * @param s 用来生成元素的 {@link Supplier} + * @param s 用来生成元素的 {@link Supplier} * @return 无限串行无序流 */ public static EasyStream generate(final Supplier s) { @@ -294,8 +296,8 @@ public class EasyStream extends AbstractEnhancedWrappedStream从重复串行流进行拼接时可能会导致深度调用链甚至抛出 {@code StackOverflowException}

* * @param 元素类型 - * @param a 第一个流 - * @param b 第二个流 + * @param a 第一个流 + * @param b 第二个流 * @return 拼接两个流之后的流 */ public static EasyStream concat(final Stream a, final Stream b) { @@ -305,13 +307,13 @@ public class EasyStream extends AbstractEnhancedWrappedStream split(final CharSequence str, final String regex) { return Opt.ofBlankAble(str).map(CharSequence::toString).map(s -> s.split(regex)).map(EasyStream::of) - .orElseGet(EasyStream::empty); + .orElseGet(EasyStream::empty); } // --------------------------------------------------------------- Static method end @@ -322,7 +324,7 @@ public class EasyStream extends AbstractEnhancedWrappedStream 函数执行后返回的类型 + * @param 函数执行后返回的类型 * @return 返回叠加操作后的流 */ @Override @@ -378,8 +380,8 @@ public class EasyStream extends AbstractEnhancedWrappedStream 数字 - * @param mapper 将对象转换为{@link Number} 的 {@link Function} + * @param 数字 + * @param mapper 将对象转换为{@link Number} 的 {@link Function} * @return {@link BigDecimal} , 如果流为空, 返回 {@link BigDecimal#ZERO} */ public BigDecimal sum(final Function mapper) { @@ -402,7 +404,7 @@ public class EasyStream extends AbstractEnhancedWrappedStream avg(final Function mapper, final int scale) { @@ -412,20 +414,20 @@ public class EasyStream extends AbstractEnhancedWrappedStream avg(final Function mapper, final int scale, - final RoundingMode roundingMode) { + final RoundingMode roundingMode) { //元素列表 final List bigDecimalList = stream.map(mapper).collect(Collectors.toList()); if (CollUtil.isEmpty(bigDecimalList)) { return Opt.empty(); } return Opt.ofNullable(EasyStream.of(bigDecimalList).reduce(BigDecimal.ZERO, BigDecimal::add) - .divide(NumberUtil.toBigDecimal(bigDecimalList.size()), scale, roundingMode)); + .divide(NumberUtil.toBigDecimal(bigDecimalList.size()), scale, roundingMode)); } @@ -474,9 +476,9 @@ public class EasyStream extends AbstractEnhancedWrappedStream{@code + *
{@code
 		 * 										    accept(t)
 		 * 										    return this;
 		 *                                    }