[안드로이드] rxjava로 실시간 검색기능 만들기(debounce)

일단 dependencies추가하고 sync합니다.

dependencies {
    implementation 'io.reactivex.rxjava3:rxandroid:3.0.0'
    implementation 'io.reactivex.rxjava3:rxjava:3.0.7'
    implementation 'com.jakewharton.rxbinding4:rxbinding:4.0.0'
}

 

rxjava를 활용해서 xml의 EditText를 관찰하기 위해 RxAndroidUtils라는 클래스를 하나 생성해줍니다.

public class RxAndroidUtils {
    private static final String RXTAG = RxAndroidUtils.class.getSimpleName();
    private static RxAndroidUtils instance;

    private RxAndroidUtils(){}

    public static RxAndroidUtils getInstance(){
        if(instance == null)
            instance = new RxAndroidUtils();
        return instance;
    }

    public Observable<String> getEditTextObservable(EditText editText){
        return RxTextView.textChanges(editText).map(charSequence -> charSequence.toString());
    }

    public String getTAG(){
        return RXTAG;
    }
}

 

이후에 원하는 main에서 Disposable을 하나 생성하고(나중에 옵져버블 버릴려고)

debounce로 약간의 딜레이를 주고(안그러면 타이핑하기 전에 계속 검색됨)  

subscribe에서 원하는 기능을 구현하면 됩니다.

private Disposable ET_Observable_Disposable;

Observable<String> editTextObservable =
                RxAndroidUtils.getInstance().getEditTextObservable(binding.searchET);

ET_Observable_Disposable = editTextObservable
                .debounce(500, TimeUnit.MILLISECONDS) //디바운스로 500만큼 검색딜레이
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(s->{ //EditText의 내용을 s로 받아온 겁니다.
                /////////////////////////////////////////////////////////////원하는 기능추가
                    Log.d(RxAndroidUtils.getInstance().getTAG(),s);
                    if(s.length() >= 2) {
                        Loaded_Posts.clear();
                        adapter.NoMore_Load(true);
                        KeyWord = s;
                        Search(KeyWord);
                    }
                    else if(s.length() == 1){
                        Toast.makeText(this,"두 글자 이상 적어주세요.",Toast.LENGTH_SHORT).show();
                    }
                    /////////////////////////////////////////////////////////////
 });

 

이후에 activity가 onDestroy되면 아까 만든 Disposable로 observable을 제거해줍니다.

@Override
    protected void onDestroy() {
        super.onDestroy();
        ET_Observable_Disposable.dispose();
    }

 

그러면 아래처럼 됩니다!

타이핑할 때마다 자동으로 검색되니까 버튼이 필요없다?!

 

참고블로그:

https://taehyungk.github.io/posts/android-RxJava2-Disposable/

[RxJava2] Disposable - 메모리 누수를 막아보자

https://onlyfor-me-blog.tistory.com/415

[Rxjava] Disposable이란? CompositeDisposable이란?

https://black-jin0427.tistory.com/74

[Android, RxBinding] RxBinding 사용기

https://terry-some.tistory.com/48

RxJava를 사용한 Debounce 구현

https://selfish-developer.com/entry/RxJava-Observable-Observer

RxJava - Observable, Observer