Stream API

Stream API

List<String> names = new ArrayList<>();

names.add("chanhong");
names.add("pig");

• 연속된 데이터를 처리하는 연산(Operation)들의 모음
• Functional in nature, 스트림이 처리하는 데이터 소스를 변경하지 않는다.

  Stream<String> stringStream = neames.stream().map(String::toUpperCase);
  
  names.forEach(System.out::println);

• 스트림으로 처리하는 데이터는 오직 한번만 처리한다.
• 손 쉽게 병렬 처리할 수 있다. (parallelStream())
• 중개 오퍼레이션은 근본적으로 lazy하다.

스트림 파이프라인

• 0 또는 다수의 중계 오퍼레이션과 한개의 종료 오퍼레이션으로 구성된다.
• 스트림의 데이터 소스는 오직 터미널 오퍼레이션을 실행할 때에만 처리한다.

중개 오퍼레이션

• Stream을 리턴한다.

종료 오퍼레이션

• Stream을 리턴하지 않는다.

Stream<String> stringStream = names.stream().map((s) -> {
		System.out.println(s);
		return s.toUpperCase();
});

List<String> collect = names.stream().map((s) -> {
		System.out.println(s);
		return s.toUpperCase();
}).collect(Collectors.toList());

collect.forEach(System.out::println

스트림 API 사용 예제

List<OnlineClass> springClasses = new ArrayList<>();
        springClasses.add(new OnlineClass(1, "spring boot", true));
        springClasses.add(new OnlineClass(2, "spring data jpa", true));
        springClasses.add(new OnlineClass(3, "spring mvc", false));
        springClasses.add(new OnlineClass(4, "spring core", false));
        springClasses.add(new OnlineClass(5, "rest api development", false));

걸러내기

• Filter(Predicate)

System.out.println("spring 으로 시작하는 수업");
        springClasses.stream()
                .filter(oc -> oc.getTitle().startsWith("spring"))
                .forEach(oc -> System.out.println(oc.getId()));

변경하기

• Map 또는 FlatMap

System.out.println("수업 이름만 모아서 스트림 만들기");
        springClasses.stream()
                .map(oc -> oc.getTitle())
                .forEach(s -> System.out.println(s));

생성하기

• generate 또는 Iterate

System.out.println("10부터 1씩 증가하는 무제한 스트림 중에서 앞에 10개 빼고 최대 10개 까지만");
Stream.iterate(10, i -> i + 1)
                .skip(10)
                .limit(10)
                .forEach(System.out::println);

제한하기

• limit 또는 skip

System.out.println("자바 수업 중에 Test가 들어있는 수업이 있는지 확인");
        boolean test = javaClasses.stream().anyMatch(oc -> oc.getTitle().contains("Test"));
        System.out.println(test);

        System.out.println("스프링 수업 중에 제목에 spring이 들어간 것만 모아서 List로 만들기")
        List<String> spring = springClasses.stream()
                .map(OnlineClass::getTitle)
                .filter(t -> t.contains("spring"))
                .collect(Collectors.toList());
        spring.forEach(System.out::println);