RxJava fromXXX 함수에 대하여 2탄

fromFuture()

Future 인터페이스 역시 자바 5에서 추가된 동시성 API로 비동기 계산의 결과를 구할 때 사용합니다 보통 Executor 인터페이스를 구현한 클래스에 Callable 객체를 인자로 넣어 Future 객체를 반환합니다 get() 메소드를 호출하면 Callable 객체에서 구현한 계산 결과가 나올 때 까지 블로킹 됩니다

 

Callable 인터페이스의 call() 메소드는 인자가 없으므로 ()->{} 형태로 나타냈습니다

실행 결과는 1초 쉬고 Hello Future 가 출력됩니다! 

참고로 Executors 클래스는 단일 스레드 실행자(SingleThreadExecutor) 뿐만 아니라 다양한 스레드풀(FixedThreadPool, CachedThreadPool) 을 지원합니다 하지만 RxJava는 위 와 같은 실행자를 활용하기 보다 RxJava에서 제공하는 스케줄러를 활용하도록 권장합니다!!! 

 

fromPublisher()

Observable에서 제공하는 fromXXX() 함수 계열의 마지막 입니다!!! Publisher 는 자바 9 의 표준인 FlowAPI의 일부입니다 

전에 학습했던 Observable.create() 와 마찬가지로 onNext() 와 onComplete() 함수를 호출 할 수 있습니다!!