Android RxJava2 함수에 대해 알아보자 -공통적으로 사용하는 구독(수신)클래스 static class CustomSubscriber extends DisposableSubscriber{ @Override public void onNext(T t){ } @Override public void onError(Throwable t){ } @Override public void onComplete(){ } } 1.Just 파라미터를 통해 받은 데이터로 Flowable을 생성하는 연산자입니다. 최대 10까지 전달할 수 있고, 모든데이터가 수신되면 onComplete()수신. 기본적인 Flowable 생성자 함수로 볼 수 있으며 단순 작업에서 많이 사용. //파라미터 값을 순차적으로 송신하는 Flowab..

RxJava에 대해 알아보자 RxJava -reactive programming을 하기 위한 라이브러리인 Rx(reactive extensions)의 JVM판. -reactive streams는 java8+에 친화적 -이벤트를 정의한 'Observable' 인스턴스에 대해 짧은 함수를 엮은(체인) 스트림 같이 이벤트 결과 데이터를 가공하는 처리를 정의, 지연실행, 비동기 콜백을 할 수 있다. -Rxjava2.x에서는 Observable, Single, Maybe, Flowable로 클래스를 구분 1.null을 보내게 되면 바로 nullpointerException처리. ->completable, maybe 활용 가능 2.Flowable은 Backpressure를 지원하는 Observable이다. 3.Su..

map() 함수 -입력값을 어떤 함수에 넣어서 원하는 값으로 변환하는 함수. String을 String으로 변환할 수도 있고, String을 Integer나 다른 객체로도 변환할 수 있음 map() 핵심 -내가 원하는 값을 ‘어떤 함수’ 에 넣는 것 -어떤 함수 : Function 인터페이스 객체 / 람다 표현식 -원하는 함수를 정의할 수 있느냐가 관건 flatMap() 함수 -map()을 좀 더 발전시킨 함수 -결과가 Observable로 나옴 -flatMap() => 일대다 or 일대일 Observable 함수 map() => 일대일 함수 RxJava에서 여러 개의 데이터를 발행하는 방법은 Observable 밖에 없음 (배압(back pressure)을 고려하면 Observable 대신에 Flowa..