Subject클래스 (AsyncSubject, BehaviorSubject, PublishSubject, ReplaySubject 등 ) AsyncSubject 클래스 Observable에서 발행한 마지막 데이터를 얻어올 수 있는 Subject 클래스 입니다. 완료되기 전 마지막 데이터에만 관심이 있으며 이전 데이터는 무시합니다. AsyncSubject 클래스의 마블다이어 그램입니다. 이 다이어 그램을 보면, 방금 위에서 설명한 마지막 데이터에만 관심이 있다는 말이 쉽게 와 닿습니다. 처음 구독자가 subscribe() 함수를 호출합니다. 후에 첫번째 원, 두번째 원이 발행된 후, 두번째 구독자가 subscribe() 함수를 호출합니다. 마지막으로 세번째 원이 발행된후, 데이터 발행을 완료하는 onCom..

Observable에는 뜨거운Observable (Hot Observable) 과 차가운 Observable(Cold Observable)이 있습니다.차가운 Observable은 마치 냉장고에 들어있는 냉동식품과 같습니다. Observable을 선언하고 just(), fromIterable() 함수를 호출해도 옵저버가 subscribe() 함수를 호출하여 구독하지 않으면 데이터를 발행하지 않습니다. 다른말고 게으른 Lazy 접근법 임니다. 뜨거운 Observable은 구독자의 존재 여부와 관계없이 데이터를 발행하는 Observable입니다. 따라서 여러 구독자를 고려할 수 있습니다. 단, 구독자로서는 Observable에서 발행하는 데이터를 처음부터 모두 수신할 것으로 보장할 수 없습니다.즉, 차가운 O..

자바코드를 작성하기위한 파일은 기존의 자바 코드 파일을 생성하는 것과 동일합니다.[New] - [Class] 에서 [Name]에 원하는 파일명을 입력후 해주면 됩니다. package reactivejava; import io.reactivex.Observable; public class FirstExample { public void emit() { Observable.just("Hello", "RxJava 2!!").subscribe(System.out::println); } public static void main(String[] args) { FirstExample demo = new FirstExample(); demo.emit(); } } 위 코드 내용을 입력후 실행해 봅시다. HelloRxJ..

실습은 이클림스 IDE를 이용해 진행합니다. 빌드 도구는 그레이들(Gradle)을 사용합니다.이클립스 Oxygen은 기본으로 그레이들을 지원합니다.만약 하위 버전일 경우 아래와 같이 이클립스 마켓에서 [INSTALL] 해주시면 됩니다.아래 그림처럼 이클립스 마켓에서 Find 에 buildship 을 입력 후 검색해 줍니다. Gradle Integration 2.0 이 검색되면 오른쪽에 [INSTALL] 버튼 눌러 설치해 줍니다. Installed 라면 이미 그레이들이 설치되어 있는 상태 입니다. 설치가 완료 되었다면, 프로젝트를 만들어 봅시다. 이클립스에서 그레이들 기반의 자바 프로젝트를 만들고 싶다면 아래 그림처럼 [File] - [New] - [Project...] 를 선택한 후 [Gradle] - ..