Rxjava
-
Cold / Hot ObservableRxjava 2021. 2. 27. 21:35
Cold Observable - Observable을 선언하고 just(item : T)를 호출해도 Observer가 subscribe() 함수를 호출하여 구독하지 않으면 데이터를 발행시키지 않음 - subscribe() 함수를 호출하면 준비된 데이터를 처음부터 발행 Hot Observable - 구독한 시점부터 Observable에서 발행되는 데이터를 받는다. - 구독자 여부 존재와 관계 없이 데이터를 발행한다. 대신 데이터가 처음부터 발행된 데이터인지를 보장할 수없다 - 위처럼 데이터 발행하는 속도와 구독자에게 처리하는 속도의 차이가 클 때 Buffer를 사용하여 처리해야 함
-
Observable , Single, maybeRxjava 2021. 2. 27. 18:14
Observable - Rx의 기본 단위 - Observable의 Event는 onNext() , onError() , onComplete() 호출 onNext() : 데이터가 발생되었을 때 호출 onError() : stream 처리 또는 데이터 발생 중 에러 발생 onComplete() : 모든 데이터를 에러없이 내 보냈을 때 호출 1. Just() argument로 담은 데이터를 차례대로 발행한다. 다음과 같이 원에 담긴 데이터를 그대로 출력하고 마지막에 onComplete를 호출한다. 2. Create() just()와 다르게 개발자가 직접 이벤트를 처리해야 함 3. fromArray() 배열 처리 4. fromIterable() Iterable을 상속하는 list 항목들에 대해 처리 (뭐.. 거..