[리액티브(Reactive) 프로그래밍] 데이터 집계 연산자

데이터 집계 연산자

count

출처 - https://reactivex.io/RxJava/2.x/javadoc/io/reactivex/Flowable.html

• Observable이 통지한 데이터의 총 개수를 통지함
• 총 개수만 통지하면 되므로 결과값은 Single로 반환함
• 데이터의 총 개수를 통지하는 시점은 완료 통지를 받은 시점임

reduce

출처 - https://reactivex.io/RxJava/2.x/javadoc/io/reactivex/Flowable.html

• Observable이 통지한 데이터를 이용해서 어떤 결과를 일정한 방식으로 합성한 후, 최종 결과를 반환함
• Observable이 통지한 데이터가 숫자일 경우 파라미터로 지정한 함수형 인터페이스에 정의된 계산 방식으로 값을 집계할 수 있음

 

퀴즈.

range, reduce 함수를 이용하여 10부터 1까지 역순으로 뺄셈을 한 최종 결과 값을 구하세요.
예) 10 - 9 - 8 - 7 - 6 - 5 - 4 - 3 - 2 - 1 = -35

public class quiz1 {
    public static void main(String[] args) {
        final int seed = 10;
        Observable.range(1, 9)
                .reduce(seed, (x, y) -> {
                    int b = seed - y;
                    return x - b;
                })
                .subscribe(data -> System.out.println(data));
    }
}

---

출처 : 인프런 (Kevin의 알기쉬운 RxJava) 

Kevin의 알기 쉬운 RxJava 1부 강의 | Kevin - 인프런