×
Crocus
공부한 내용을 정리하는 블로그로 시작한
Crocus는 2014년 1월 14일 부터 시작하여
현재 월 6만명, 총 2,101,837명의 방문자 수를 기록하고 있습니다.
Donation
이제 많은 사용자들이 이용하는 만큼
더 다양한 서비스 개발/제공을 위해 후원금을 모금하고자 합니다.
후원을 해주시는 분들은 Donators 명단에 성명, 후원금을 기입해드리며
Crocus 블로그가 아닌 다른 곳에 정리해둔 저만의 내용을 공유해 드리고자 합니다.
Account
예금주 : 고관우
신한은행 : 110-334-866541
카카오뱅크 : 3333-01-7888060

👉 후원 페이지 바로가기 Donators
익명 : 5000원(Crocus응원합니다.)
busyhuman: 5000원(유용한 지식 감사합니다.)
익명 : 5000원(알고리즘 학습러)
반응형

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
반응형