update stream流工具类其他方法过滤null值

feature/model
bleachtred 1 year ago
parent 64b0748bf1
commit 1f303ff1de

@ -72,7 +72,7 @@ public class StreamUtils {
return CollUtil.newArrayList(); return CollUtil.newArrayList();
} }
// 注意此处不要使用 .toList() 新语法 因为返回的是不可变List 会导致序列化问题 // 注意此处不要使用 .toList() 新语法 因为返回的是不可变List 会导致序列化问题
return collection.stream().sorted(comparing).collect(Collectors.toList()); return collection.stream().filter(Objects::nonNull).sorted(comparing).collect(Collectors.toList());
} }
/** /**
@ -89,7 +89,7 @@ public class StreamUtils {
if (CollUtil.isEmpty(collection)) { if (CollUtil.isEmpty(collection)) {
return MapUtil.newHashMap(); return MapUtil.newHashMap();
} }
return collection.stream().collect(Collectors.toMap(key, Function.identity(), (l, r) -> l)); return collection.stream().filter(Objects::nonNull).collect(Collectors.toMap(key, Function.identity(), (l, r) -> l));
} }
/** /**
@ -108,7 +108,7 @@ public class StreamUtils {
if (CollUtil.isEmpty(collection)) { if (CollUtil.isEmpty(collection)) {
return MapUtil.newHashMap(); return MapUtil.newHashMap();
} }
return collection.stream().collect(Collectors.toMap(key, value, (l, r) -> l)); return collection.stream().filter(Objects::nonNull).collect(Collectors.toMap(key, value, (l, r) -> l));
} }
/** /**
@ -126,7 +126,7 @@ public class StreamUtils {
return MapUtil.newHashMap(); return MapUtil.newHashMap();
} }
return collection return collection
.stream() .stream().filter(Objects::nonNull)
.collect(Collectors.groupingBy(key, LinkedHashMap::new, Collectors.toList())); .collect(Collectors.groupingBy(key, LinkedHashMap::new, Collectors.toList()));
} }
@ -147,7 +147,7 @@ public class StreamUtils {
return MapUtil.newHashMap(); return MapUtil.newHashMap();
} }
return collection return collection
.stream() .stream().filter(Objects::nonNull)
.collect(Collectors.groupingBy(key1, LinkedHashMap::new, Collectors.groupingBy(key2, LinkedHashMap::new, Collectors.toList()))); .collect(Collectors.groupingBy(key1, LinkedHashMap::new, Collectors.groupingBy(key2, LinkedHashMap::new, Collectors.toList())));
} }
@ -168,7 +168,7 @@ public class StreamUtils {
return MapUtil.newHashMap(); return MapUtil.newHashMap();
} }
return collection return collection
.stream() .stream().filter(Objects::nonNull)
.collect(Collectors.groupingBy(key1, LinkedHashMap::new, Collectors.toMap(key2, Function.identity(), (l, r) -> l))); .collect(Collectors.groupingBy(key1, LinkedHashMap::new, Collectors.toMap(key2, Function.identity(), (l, r) -> l)));
} }

Loading…
Cancel
Save