세상을 바꾸는 개발자

안녕하세요 헬창코딩입니다. 오늘은 Observable의 다양한 형태에 대해서 알아보도록 하겠습니다!! Single SIngle은 Observable과는 다르게 단 하나의 아이템만을 발행하는 특징이 있습니다. 그러므로 저번 포스팅에서 알아보았던 just() 연산자에는 하나의 인자만을 취할 수 있습니다. Single.just("health coding").subscribe(t -> Log.d("log_test", "" + t)); create() 연산자를 사용하는 경우 Emitter를 이용하여 데이터를 발행합니다. 데이터를 단 한 번만 발행하므로 onNext()와 onComplete() 메서드를 호출하는 대신 onSuccess(T)로 두메 서드를 대체합니다. Single.create(emitter -> em..

안녕하세요~ 헬창코딩입니다. 오늘은 Observerble에 대해서 알아보도록 하겠습니다~ RxJava에서는 Obseverble을 구독(subscribe)하는 Observer가 존재하고, Observable이 순차적으로 발행하는 데이터에 대해서 반응합니다. 이때 Observable은 다음과 같이 3가지 이벤트를 사요하여 동작합니다.! onNext() : 하나의 소스 Observable에서 Observer까지 한 번에 하나씩 순차적으로 데이터를 발행합니다. onComplete() : 데이터 발행이 끝났음을 알리는 완료 이벤트를 Observer에 전달하여 더는 onNext() 호출이 발생하지 않음을 나타냅니다. onError() : 오류가 발생했음을 Observer에 전달합니다. 이 세 가지 이벤트 메서드들은..