간단한 RxJava Observable 예제

Log.v(TAG, "FlatMap을 통해 데이터를 변경");

 

해당 아래 코드부터 설명하자면 다음과 같다.

 

observable는 3,1,2,5,4 데이터를 보내고 있으며

이때 map을 통해 integer * 2를 하여 총 6,2,4,10,8이 된다.

 

그 후 sort를하여 오름차순 정렬한 observable(Single)은 2,4,6,8,10이 되고

이때 flatMapObservable을 통해 해당 Observable이 ★이었다면 observable2는 ■형태로 변하게 되는 모습을 볼 수 있게 된다. 그리하여 doOnNext를 출력하면 2,4가 나오게 된다. ("2","4"가 있는 데이터만 필터링)

package com.demo.testing;

import androidx.appcompat.app.AppCompatActivity;

import android.os.Bundle;
import android.util.Log;
import io.reactivex.rxjava3.core.Observable;

public class MainActivity extends AppCompatActivity {
    private static final String TAG = "CROCUS";

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        Log.v(TAG, "Observable을 통해 구독한 후 출력");
       Observable<Integer> observable = Observable.just(3,1,2,5,4);

       observable
               .doOnNext(integer -> Log.v(TAG, String.valueOf(integer)))
               .subscribe();

        Log.v(TAG, "Map을 통해 데이터를 변경");
        observable
                .map(integer -> integer * 2)
                .doOnNext(integer -> Log.v(TAG, String.valueOf(integer)))
                .toSortedList((o1, o2) -> o1 - o2)
                .doOnSuccess(integers -> Log.v(TAG, String.valueOf(integers)))
                .subscribe();

        Log.v(TAG, "FlatMap을 통해 데이터를 변경");
        Observable<String> observable2 = Observable.just("2","4");
        observable
                .map(integer -> integer * 2)
                .doOnNext(integer -> Log.v(TAG, String.valueOf("전 : " + integer)))
                .toSortedList((o1, o2) -> o1 - o2)
                .flatMapObservable(integers -> observable2.filter(s -> integers.contains(Integer.parseInt(s))))
                .doOnNext(integers -> Log.v(TAG, String.valueOf("후 : " + integers)))
                .subscribe();
    }
}

 

2021-06-01 00:21:00.994 V/CROCUS: Observable을 통해 구독한 후 출력
2021-06-01 00:21:01.021 V/CROCUS: 3
2021-06-01 00:21:01.022 V/CROCUS: 1
2021-06-01 00:21:01.022 V/CROCUS: 2
2021-06-01 00:21:01.022 V/CROCUS: 5
2021-06-01 00:21:01.022 V/CROCUS: 4
2021-06-01 00:21:01.022 V/CROCUS: Map을 통해 데이터를 변경
2021-06-01 00:21:01.033 V/CROCUS: 6
2021-06-01 00:21:01.034 V/CROCUS: 2
2021-06-01 00:21:01.034 V/CROCUS: 4
2021-06-01 00:21:01.034 V/CROCUS: 10
2021-06-01 00:21:01.034 V/CROCUS: 8
2021-06-01 00:21:01.034 V/CROCUS: [2, 4, 6, 8, 10]
2021-06-01 00:21:01.034 V/CROCUS: FlatMap을 통해 데이터를 변경
2021-06-01 00:21:01.035 V/CROCUS: 전 : 6
2021-06-01 00:21:01.035 V/CROCUS: 전 : 2
2021-06-01 00:21:01.035 V/CROCUS: 전 : 4
2021-06-01 00:21:01.035 V/CROCUS: 전 : 10
2021-06-01 00:21:01.036 V/CROCUS: 전 : 8
2021-06-01 00:21:01.036 V/CROCUS: 후 : 2
2021-06-01 00:21:01.036 V/CROCUS: 후 : 4