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 0d5b22f14..90de48122 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 @@ -342,7 +342,7 @@ public class EasyStream extends AbstractEnhancedWrappedStream>> recursiveRef = new MutableObj<>(); final Consumer> recursive = values -> EasyStream.of(values, isParallel()).forEach(value -> { - List children = pIdValuesMap.get(idGetter.apply(value)); + final List children = pIdValuesMap.get(idGetter.apply(value)); childrenSetter.accept(value, children); recursiveRef.get().accept(children); }); diff --git a/hutool-core/src/main/java/cn/hutool/core/stream/TerminableWrappedStream.java b/hutool-core/src/main/java/cn/hutool/core/stream/TerminableWrappedStream.java index d2a09ef7b..e4b7daa81 100644 --- a/hutool-core/src/main/java/cn/hutool/core/stream/TerminableWrappedStream.java +++ b/hutool-core/src/main/java/cn/hutool/core/stream/TerminableWrappedStream.java @@ -173,10 +173,10 @@ public interface TerminableWrappedStream> M toMap( - final Function keyMapper, - final Function valueMapper, - final BinaryOperator mergeFunction, - Supplier mapSupplier) { + final Function keyMapper, + final Function valueMapper, + final BinaryOperator mergeFunction, + final Supplier mapSupplier) { Objects.requireNonNull(keyMapper); Objects.requireNonNull(valueMapper); Objects.requireNonNull(mergeFunction); @@ -205,7 +205,7 @@ public interface TerminableWrappedStream keyList = toList(); final Map map = new HashMap<>(keyList.size()); - for (T key : keyList) { + for (final T key : keyList) { map.put(key, iterator.hasNext() ? iterator.next() : null); } return map; 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 b689db3fa..3af5de3b8 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 @@ -155,6 +155,7 @@ public interface TransformableWrappedStream elements = unwrap().collect(Collectors.toList()); return wrap(ListUtil.splice(elements, start, deleteCount, items).stream()) @@ -279,7 +280,7 @@ public interface TransformableWrappedStream action.accept(e, NOT_FOUND_ELEMENT_INDEX)); } else { - AtomicInteger index = new AtomicInteger(NOT_FOUND_ELEMENT_INDEX); + final AtomicInteger index = new AtomicInteger(NOT_FOUND_ELEMENT_INDEX); return peek(e -> action.accept(e, index.incrementAndGet())); } } @@ -318,6 +319,7 @@ public interface TransformableWrappedStream result = unwrap(); if (ArrayUtil.isNotEmpty(obj)) { @@ -489,6 +491,7 @@ public interface TransformableWrappedStream>> recursiveRef = new MutableObj<>(); + @SuppressWarnings("unchecked") final Function> recursive = e -> EasyStream.of(childrenGetter.apply(e)) .flat(recursiveRef.get()) .unshift(e); diff --git a/hutool-core/src/main/java/cn/hutool/core/stream/WrappedStream.java b/hutool-core/src/main/java/cn/hutool/core/stream/WrappedStream.java index 8f9399f16..7e503226a 100644 --- a/hutool-core/src/main/java/cn/hutool/core/stream/WrappedStream.java +++ b/hutool-core/src/main/java/cn/hutool/core/stream/WrappedStream.java @@ -269,6 +269,7 @@ public interface WrappedStream> extends Stream< @Override default A[] toArray(final IntFunction generator) { Objects.requireNonNull(generator); + //noinspection SuspiciousToArrayCall return unwrap().toArray(generator); } @@ -547,7 +548,7 @@ public interface WrappedStream> extends Stream< * @return 流 */ @Override - default S onClose(Runnable closeHandler) { + default S onClose(final Runnable closeHandler) { return wrap(unwrap().onClose(closeHandler)); }