安全创建 Java Stream

使用示例：

package bigcrab;

import java.util.Arrays;
import java.util.List;
import java.util.Map;

/**
 * @author sky
 * @date 2020/3/5
 */
public class TestCreateStream {

    public void run() {
        List<Integer> list = Arrays.asList(1, 2, 3, 4, 5);
        DataUtils.asStream(list).forEach(System.out::println);

        Map<Integer, String> map = null;
        DataUtils.asStream(map).forEach(System.out::println);
    }
}

DataUtils 类定义：

package bigcrab;

import java.util.Collection;
import java.util.Map;
import java.util.stream.Stream;

/**
 * @author sky
 * @date 2020/3/5
 */
public class DataUtils {

    /**
     * 基于 Collection 安全地获得一个 stream 对象
     *
     * @param collection
     * @param <T>
     * @return
     */
    public static <T> Stream<T> asStream(Collection<T> collection) {
        return collection == null ? Stream.empty() : collection.stream();
    }

    /**
     * 基于 Map 安全地获取一个 stream 对象
     *
     * @param map
     * @param <K>
     * @param <V>
     * @return
     */
    public static <K, V> Stream<Map.Entry<K, V>> asStream(Map<K, V> map) {
        if (map == null || map.size() == 0) {
            return Stream.empty();
        }
        return asStream(map.entrySet());
    }

    /**
     * 基于 Collection 安全地获得一个并行的 stream 对象
     *
     * @param collection
     * @param <T>
     * @return
     */
    public static <T> Stream<T> asParallelStream(Collection<T> collection) {
        return collection == null ? Stream.empty() : collection.parallelStream();
    }

    /**
     * 基于 Map 安全地获得一个并行的 stream 对象
     *
     * @param map
     * @param <K>
     * @param <V>
     * @return
     */
    public static <K, V> Stream<Map.Entry<K, V>> asParallelStream(Map<K, V> map) {
        if (map == null || map.size() == 0) {
            return Stream.empty();
        }
        return asParallelStream(map.entrySet());
    }

}