스트림 파이프라인 원리

Java code

import java.util.*;
import java.util.stream.*;

public class StreamPipeline {
    public static void main(String[] args) {
        List<String> names = List.of("Alice", "Bob", "Charlie", "Dave", "Eve");

        // 지연 평가 — 최종 연산 전까지 실행 안 됨
        Stream<String> stream = names.stream()
            .filter(n -> {
                System.out.println("filter: " + n);
                return n.length() > 3;
            })
            .map(n -> {
                System.out.println("map: " + n);
                return n.toUpperCase();
            });
        // 여기까지 아무것도 출력 안 됨!

        // 최종 연산이 파이프라인 실행
        List<String> result = stream.toList();
        // filter: Alice -> map: Alice
        // filter: Bob (통과 못 함)
        // filter: Charlie -> map: Charlie
        // filter: Dave -> map: Dave
        // filter: Eve (통과 못 함)

        // 단축 연산 — 필요한 만큼만 처리
        Optional<String> first = names.stream()
            .filter(n -> n.startsWith("C"))
            .findFirst(); // Charlie 찾으면 즉시 중단
        System.out.println(first.orElse("없음"));

        // 스트림은 일회용!
        // stream.toList(); // IllegalStateException
    }
}