diff --git a/hutool-core/src/main/java/cn/hutool/core/stream/EasyStream.java b/hutool-core/src/main/java/cn/hutool/core/stream/EasyStream.java index d6ff7879b..03f1e38e7 100644 --- a/hutool-core/src/main/java/cn/hutool/core/stream/EasyStream.java +++ b/hutool-core/src/main/java/cn/hutool/core/stream/EasyStream.java @@ -40,6 +40,7 @@ import java.util.stream.StreamSupport; * * 不同类型的流可以通过{@link #sequential()}或{@link #parallel()}互相转换。 * + * @param 对象类型 * @author VampireAchao * @author emptypoint * @author huangchengxing @@ -270,7 +271,7 @@ public class EasyStream extends AbstractEnhancedWrappedStream transform(Stream stream) { + public EasyStream transform(final Stream stream) { this.stream = stream; return this; } diff --git a/hutool-core/src/main/java/cn/hutool/core/stream/StreamUtil.java b/hutool-core/src/main/java/cn/hutool/core/stream/StreamUtil.java index 882599b71..23e64e57c 100644 --- a/hutool-core/src/main/java/cn/hutool/core/stream/StreamUtil.java +++ b/hutool-core/src/main/java/cn/hutool/core/stream/StreamUtil.java @@ -32,6 +32,11 @@ import static java.util.Objects.requireNonNull; */ public class StreamUtil { + /** + * @param array 数组 + * @param 元素类型 + * @return {@link Stream} + */ @SafeVarargs public static Stream of(final T... array) { Assert.notNull(array, "Array must be not null!"); @@ -66,8 +71,9 @@ public class StreamUtil { /** * {@link Iterator} 转换为 {@link Stream} + * * @param iterator 迭代器 - * @param 集合元素类型 + * @param 集合元素类型 * @return {@link Stream} * @throws IllegalArgumentException 如果iterator为null,抛出该异常 */ @@ -77,9 +83,10 @@ public class StreamUtil { /** * {@link Iterator} 转换为 {@link Stream} + * * @param iterator 迭代器 * @param parallel 是否并行 - * @param 集合元素类型 + * @param 集合元素类型 * @return {@link Stream} * @throws IllegalArgumentException 如果iterator为null,抛出该异常 */ diff --git a/hutool-core/src/main/java/cn/hutool/core/stream/TransformableWrappedStream.java b/hutool-core/src/main/java/cn/hutool/core/stream/TransformableWrappedStream.java index ef85e8ad1..67ea84996 100644 --- a/hutool-core/src/main/java/cn/hutool/core/stream/TransformableWrappedStream.java +++ b/hutool-core/src/main/java/cn/hutool/core/stream/TransformableWrappedStream.java @@ -42,8 +42,8 @@ public interface TransformableWrappedStream other, final BiFunction zipper) { Objects.requireNonNull(zipper); - Map idxIdentityMap = mapIdx((e, idx) -> MapUtil.entry(idx, e)).collect(CollectorUtil.entryToMap()); - Map idxOtherMap = EasyStream.of(other).mapIdx((e, idx) -> MapUtil.entry(idx, e)).collect(CollectorUtil.entryToMap()); + final Map idxIdentityMap = mapIdx((e, idx) -> MapUtil.entry(idx, e)).collect(CollectorUtil.entryToMap()); + final Map idxOtherMap = EasyStream.of(other).mapIdx((e, idx) -> MapUtil.entry(idx, e)).collect(CollectorUtil.entryToMap()); if (idxIdentityMap.size() <= idxOtherMap.size()) { return EasyStream.of(idxIdentityMap.keySet(), isParallel()).map(k -> zipper.apply(idxIdentityMap.get(k), idxOtherMap.get(k))); }