[fix] 修改为sequential

This commit is contained in:
VampireAchao 2023-06-13 11:29:25 +08:00
parent 169c625f3b
commit 5b8bbe4943

View File

@ -214,7 +214,7 @@ public interface TerminableWrappedStream<T, S extends TerminableWrappedStream<T,
*/ */
default <U> Map<Integer, U> toIdxMap(final Function<? super T, ? extends U> valueMapper) { default <U> Map<Integer, U> toIdxMap(final Function<? super T, ? extends U> valueMapper) {
final MutableInt index = new MutableInt(NOT_FOUND_ELEMENT_INDEX); final MutableInt index = new MutableInt(NOT_FOUND_ELEMENT_INDEX);
return EasyStream.of(parallel().toList()).toMap(e -> index.incrementAndGet(), valueMapper, (l, r) -> r); return EasyStream.of(sequential().toList()).toMap(e -> index.incrementAndGet(), valueMapper, (l, r) -> r);
} }
// region ============ to zip ============ // region ============ to zip ============