如何在Java中动态添加操作流？

Question

我有以下代码:

private List<EmployeeDto> doTransformation(List<Employee> employees, Optional<Predicate<Employee>> filter, Integer limit, Integer offset) {

    Stream<Employee> stream = filter.isPresent() ? employees.stream().filter( filter.get() ) : employees.stream();
    // do offset sql based for stream //not working
    if ( offset != null ) {
       stream.skip( offset );
    }    
    // do limit sql based for stream //not working
    if ( limit != null ) {
        stream.limit( limit );
    }
    return stream
        .map( employee -> /*do some mapping to EmployeeDto*/ )
        .collect( Collectors.toList() );
}

在这部分代码中：

1. 如果存在过滤器，则将过滤器应用于流；
2. 想要对此流进行一些偏移和限制，但这不起作用，因为“应该只对一个流进行一次操作（调用中间或终端流操作）”。
3. 映射到dto对象并收集为列表。

如何以其他方式进行流操作skip()和limit()。提前感谢。

Answer 1

我做了这个小例子，也许它对你的情况有用？

Integer offset = null;
Integer limit = 2;

List<String> list = new ArrayList<>(Arrays.asList("batman", "one", "seven", "woohooo", "awesomeness"));
List<Integer> lengths = list.stream()
    .skip(offset != null ? offset : 0)
    .limit(limit != null ? limit : Integer.MAX_VALUE)
    .map(String::length) //as an example of mapping
    .collect(Collectors.toList());

lengths.forEach(System.out::println);