지난주에 저는 사용자 정의 Stream 의 사용 사례 를 설명했습니다Collector . Twitter에서 흥미로운 댓글을 받았습니다.

모자 벗어, 미구엘! 귀하의 의견은 내가 몰랐던 방법을 공개했습니다!

그래서 나는 그 teeing()방법 이 무엇인지 조사하기로 결정했습니다 .

두 개의 다운 스트림 수집기가 복합 된 수집기를 반환합니다. 결과 수집기로 전달 된 모든 요소는 두 다운 스트림 수집기에 의해 처리 된 다음 지정된 병합 기능을 사용하여 결과가 최종 결과로 병합됩니다.

결과 수집기 함수는 다음을 수행합니다.

* 공급자 : 각 수집가의 공급자를 호출하여 얻은 결과 컨테이너를 포함하는 결과 컨테이너를 생성합니다.

* 누산기 : 결과 컨테이너와 입력 요소를 사용하여 각 수집기의 누산기를 호출합니다.

* 결합기 : 두 개의 결과 컨테이너를 사용하여 각 수집기의 결합기를 호출합니다.

* finisher : 결과 컨테이너를 사용하여 각 수집기의 마무리 장치를 호출 한 다음 제공된 병합기를 호출하고 결과를 반환합니다.

— JavaDocs

우리는 실제로 사용자 정의 Collector를 두 가지 간단한 Collector구현 으로 대체 할 수 있습니다 . 하나는 집계 가격 행이고 다른 하나는 카트 가격을 합산하는 것입니다.

최종 코드를보고 한 줄씩 설명해 봅시다.

public PriceAndRows getPriceAndRows(Cart cart) {
  return cart.getProducts()
      .entrySet()
      .stream()
      .map(CartRow::new)                           // 1
      .collect(Collectors.teeing(                  // 2
          Collectors.reducing(                     // 3
              BigDecimal.ZERO,                     // 4
              CartRow::getRowPrice,                // 5
              BigDecimal::add),                    // 6
          Collectors.toList(),                     // 7
          PriceAndRows::new                        // 8
      ));
}

1. teeing()메서드 호출
2. 첫 번째 수집가가 가격을 계산합니다. 다음 reducing()과 같은 간단한 호출입니다.
3. 시작 요소
4. 함수 란을 추출하는 Price(A)로부터CartRow
5. BinaryOperator두 개의 가격을 함께 추가하려면 A
6. 두 번째 수집기 CartRow는 목록으로 집계 합니다.
7. 마지막으로 마지막 매개 변수는 첫 번째 및 두 번째 수집기의 결과를 집계하는 새 개체를 만듭니다.

1. 추출 모두의 개별 구성 요소의 각 Collector, 즉 , supplier(), `accumulator(), combiner()및finisher()
2. 나란히 페어링
3. Collector쌍을 전달하여 하나의 새 를 만듭니다.

이 게시물이 사용자 정의 teeing() 를 만들기 전에 사용을 고려하게 되었기를 바랍니다 Collector. Miguel에게 다시 한 번 감사드립니다!

그건 그렇고, 나는 항상 새로운 것을 배우는 것이 행복합니다. 공유 할 정보가있는 경우 아래 댓글 시스템이나 Twitter를 사용할 수 있습니다.

이 게시물의 전체 소스 코드 는 Maven 형식의 Github 에서 찾을 수 있습니다 .

더 나아가려면 :

• Stream Collector의 실제 사례
• Java 8의 사용자 지정 수집기
• 티잉 Javadoc