[java] 자바 스트림에서 실제로는 디버깅을 위해서만 엿볼 수 있습니까?

알아야 할 중요한 점은 스트림이 터미널 작업 에 의해 구동된다는 것 입니다. 터미널 작업은 모든 요소를 ​​처리해야하는지 아니면 전혀 처리해야하는지 결정합니다. 그래서 collect반면, 각 항목을 처리하는 동작이다 findAny그것이 매칭 소자가 발생하면 처리 항목을 중지 할 수는.

그리고 count()항목을 처리하지 않고 스트림의 크기를 결정할 수 있으면 요소를 전혀 처리하지 않을 수 있습니다. 이것은 Java 8에서는 최적화되지 않았지만 Java 9에서는 최적화이기 때문에 Java 9로 전환하고 count()모든 항목 처리에 의존하는 코드가있을 경우 놀라 울 수 있습니다 . 이것은 다른 구현-의존적 세부 사항, 예를 들어 Java 9에서도 연결되어 있으며, 참조 구현은 limit이러한 예측을 막는 기본 제한이없는 동안 무한 스트림 소스의 크기를 결합 할 수는 없습니다.

peek” 요소가 결과 스트림에서 소비 될 때 각 요소에 대해 제공된 조치를 수행”할 수 있으므로 요소 처리를 요구하지는 않지만 터미널 조작에 필요한 조치에 따라 조치를 수행합니다. 즉, 특정 처리가 필요한 경우 (예 : 모든 요소에 작업을 적용하려는 경우)주의해서 사용해야합니다. 터미널 작업이 모든 항목을 처리하도록 보장되면 작동하지만 다음 개발자가 터미널 작업을 변경하지 않아야합니다 (또는 그 미묘한 측면을 잊어 버려야 함).

또한 스트림은 병렬 스트림의 경우에도 특정 조합의 연산에 대해 발생 순서를 유지하도록 보장하지만 이러한 보장은 적용되지 않습니다 peek. 목록으로 수집 할 때 결과 목록은 정렬 된 병렬 스트림에 대해 올바른 순서를 갖지만 peek작업은 임의의 순서로 동시에 호출 될 수 있습니다.

따라서 당신이 할 수있는 가장 유용한 것은 peekAPI 문서가 말하는 스트림 요소가 처리되었는지 여부를 찾는 것입니다.

이 방법은 주로 디버깅을 지원하기 위해 존재하며, 파이프 라인의 특정 지점을지나 가면서 요소를 확인하려는 경우

답변

return list.stream().map(foo->foo.getBar())
                    .peek(bar->bar.publish("HELLO"))
                    .collect(Collectors.toList());

List<Bar> bars = list.stream().map(foo->foo.getBar()).collect(Collectors.toList());
bars.forEach(bar->bar.publish("HELLO"));
return bars;

accounts.stream()
    .filter(Account::isActive)
    .peek(login)
    .collect(Collectors.toList());

accounts.stream()
    .filter(Account::isActive)
    .map(account -> {
        account.login();
        return account;
    })
    .collect(Collectors.toList());