RxJava - 수학관련 함수

수학관련 함수는 RxJavaMath를 쓰면되지만 RxJava 2.x부터는 지원을 안하기 때문에 다음을 설정해주어야 합니다.

 

dependencies {
     ....
    compile "com.github.akarnokd:rxjava3-extensions:3.0.0-RC7"
}

이를 추가하면 RxJavaMath의 함수들은 RxJava 2.x에서도 사용 가능합니다.

 

 

그럼 간단한 testCode를 보겠습니다.

 

Java

import hu.akarnokd.rxjava3.math.MathFlowable;
import io.reactivex.Flowable;
import io.reactivex.Observable;
import io.reactivex.Single;

public class Math_funtion_test {

    public static void main(String[] args){

        Integer[] data = {1,2,3,4};

        Single<Long> source = Observable.fromArray(data).count();
        source.subscribe(it-> System.out.println("Count: "+ it));


        Flowable.fromArray(data).to(MathFlowable::max).subscribe(it->System.out.println("Max: "+it));
        Flowable.fromArray(data).to(MathFlowable::min).subscribe(it->System.out.println("Min: "+it));
        Flowable.fromArray(data).to(MathFlowable::sumInt).subscribe(it->System.out.println("Sum: "+it));
        Flowable.fromArray(data).to(MathFlowable::averageDouble).subscribe(it->System.out.println("Average: "+it));

    }
}

Kotlin의 경우에는 따로 라이브러리가 존재하지 않는 것으로 보입니다.

 

결과

Count: 4
Max: 4
Min: 1
Sum: 10
Average: 2.5