ZhouXY108/hutool
1
0
Fork 0
mirror of https://gitee.com/chinabugotech/hutool.git synced 2025-04-19 03:01:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

:trollface: remove private

Browse Source
This commit is contained in:
achao 2022-08-02 09:57:25 +08:00 committed by VampireAchao
parent 236ebba3a8
commit 65ea5c2066
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
hutool-core/src/main/java/cn/hutool/core/stream/FastStream.java
View File

@ -8,6 +8,7 @@ import cn.hutool.core.lang.mutable.MutableInt;
import cn.hutool.core.lang.mutable.MutableObj; import cn.hutool.core.lang.mutable.MutableObj;
import cn.hutool.core.map.MapUtil; import cn.hutool.core.map.MapUtil;
import cn.hutool.core.text.StrUtil; import cn.hutool.core.text.StrUtil;
import cn.hutool.core.util.ArrayUtil;
import java.util.*; import java.util.*;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;
@ -60,10 +61,7 @@ public class FastStream<T> implements Stream<T>, Iterable<T> {
this.stream = stream; this.stream = stream;
} }
@SafeVarargs // --------------------------------------------------------------- Static method start
private static <E> Stream<E> ofStream(E... values) {
return Objects.isNull(values) ? Stream.empty() : Arrays.stream(values);
}
/** /**
* 返回{@code FastStream}的建造器 * 返回{@code FastStream}的建造器
@ -99,7 +97,7 @@ public class FastStream<T> implements Stream<T>, Iterable<T> {
} }
/** /**
* 返回包含单个元素的串行流, 如果值为null, 则返回空的流, 不抛出异常 * 返回包含单个元素的串行流
* *
* @param t 单个元素 * @param t 单个元素
* @param <T> 元素类型 * @param <T> 元素类型
@ -120,7 +118,7 @@ public class FastStream<T> implements Stream<T>, Iterable<T> {
@SafeVarargs @SafeVarargs
@SuppressWarnings("varargs") @SuppressWarnings("varargs")
public static <T> FastStream<T> of(T... values) { public static <T> FastStream<T> of(T... values) {
return new FastStream<>(ofStream(values)); return ArrayUtil.isEmpty(values) ? FastStream.empty() : new FastStream<>(Stream.of(values));
} }
/** /**
@ -280,6 +278,8 @@ public class FastStream<T> implements Stream<T>, Iterable<T> {
return Opt.ofBlankAble(str).map(CharSequence::toString).map(s -> s.split(regex)).map(FastStream::of).orElseGet(FastStream::empty); return Opt.ofBlankAble(str).map(CharSequence::toString).map(s -> s.split(regex)).map(FastStream::of).orElseGet(FastStream::empty);
} }
// --------------------------------------------------------------- Static method end
/** /**
* 过滤元素，返回与指定断言匹配的元素组成的流 * 过滤元素，返回与指定断言匹配的元素组成的流
* 这是一个无状态中间操作 * 这是一个无状态中间操作
@ -718,8 +718,8 @@ public class FastStream<T> implements Stream<T>, Iterable<T> {
* @throws ArrayStoreException 如果元素转换失败，例如不是该元素类型及其父类，则抛出该异常 * @throws ArrayStoreException 如果元素转换失败，例如不是该元素类型及其父类，则抛出该异常
* 例如以下代码编译正常，但运行时会抛出 {@link ArrayStoreException} * 例如以下代码编译正常，但运行时会抛出 {@link ArrayStoreException}
* <pre>{@code * <pre>{@code
* String[] strings = Stream.<Integer>builder().add(1).build().toArray(String[]::new); * String[] strings = Stream.<Integer>builder().add(1).build().toArray(String[]::new);
* }</pre> * }</pre>
*/ */
@Override @Override
public <A> A[] toArray(IntFunction<A[]> generator) { public <A> A[] toArray(IntFunction<A[]> generator) {
@ -1094,7 +1094,7 @@ public class FastStream<T> implements Stream<T>, Iterable<T> {
* @return 流 * @return 流
*/ */
public FastStream<T> push(T obj) { public FastStream<T> push(T obj) {
return FastStream.concat(this.stream, Stream.of(obj)); return FastStream.concat(this.stream, of(obj));
} }
/** /**
@ -1105,7 +1105,7 @@ public class FastStream<T> implements Stream<T>, Iterable<T> {
*/ */
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
public FastStream<T> push(T... obj) { public FastStream<T> push(T... obj) {
return FastStream.concat(this.stream, ofStream(obj)); return FastStream.concat(this.stream, of(obj));
} }
/** /**
@ -1115,7 +1115,7 @@ public class FastStream<T> implements Stream<T>, Iterable<T> {
* @return 流 * @return 流
*/ */
public FastStream<T> unshift(T obj) { public FastStream<T> unshift(T obj) {
return FastStream.concat(Stream.of(obj), this.stream); return FastStream.concat(of(obj), this.stream);
} }
/** /**
@ -1126,7 +1126,7 @@ public class FastStream<T> implements Stream<T>, Iterable<T> {
*/ */
@SafeVarargs @SafeVarargs
public final FastStream<T> unshift(T... obj) { public final FastStream<T> unshift(T... obj) {
return FastStream.concat(ofStream(obj), this.stream); return FastStream.concat(of(obj), this.stream);
} }
/** /**