[Android] Rx java Observable 기본 함수 (merge, flatMap, create,just...)

Observable.create() Lambda 표현을 쓸 수 있지만 내부 객체의 익명클래스가 어떤건지 명확하게 하기 위해서 람다표현을 사용하지 않았습니다. 사용방법은 간단한데, create함수는 onSubscribe객체를 파라미터로 가지며, 구독이 발생하면 이 객체의 call()함수가 실행됩니다. 리스너에게 콜백함수를 호출시켜주는 것과 같은원리 코드를 보자! Observable observable = Observable.create(new ObservableOnSubscribe() { @Override public void subscribe(@NonNull ObservableEmitter emitter) throws Exception { emitter.onNext(1L); } }); observable..

2021.10.18