Observable -9 (fromPubilsher함수)

본 내용은 필자가 학습한 내용을 정리하는 내용입니다. 대부분 의 내용이 아래 책의 내용이므로 원서를 구매해서 직접보시는걸 추천드립니다! RxJava 프로그래밍 리액티브 프로그래밍 기초부터 RxAndroid까지 한 번에 유동환 , 박정준 지음 | 한빛미디어 | 2017년 09월 04일 출간 http://www.kyobobook.co.kr/product/detailViewKor.laf?ejkGb=KOR&mallGb=KOR&barcode=9788968488658&orderClick=LAV&Kc=

 Observable의 팩토리 함수 구분

팩토리함수	함수
RxJava 1.x의 기본 팩토리 함수	create(),just(),from()
RxJava 2.x의 기본 팩토리 함수	fromArray(),fromlterable(),fromCallable(),fromFuture(), fromPublisher()
기타 팩토리 함수	interval(),range(),timer(),defer()

fromPublisher()함수

Observable 에서 제공하는 fromXXXX() 계열의 마지막 함수.

Publisher는 자바 9 의 표준인 Flow API의 일부입니다.(아직 자바9가 정식으로 공개된것은 아닙니다)

Publisher 인터페이스는 기존의 RxJava와 비교하면 패키이 지름이 다릅니다.

Observable은 io.reactivex 패키지 인반면

Publisher와 Subscriber클래스 패키지는 org.reactivestreams 입니다.

한편 Publisher 객체는 Observable.create()와 마찬가지로 onNext()와 onComplete()함수를 호출할 수 있습니다.

fromPublisher() 함수 활용 예

Publisher<String> publisher=(Subscriber<? super String> s)->{

            s.onNext("Hello Observable.fromPublisher()");

            s.onComplete();

};

Observable<String> source=Observable.fromPublisher(publisher);

 source.subscribe(System.out::println);

<? super String>

<? super String>A 모든 클래스 의 슈퍼 클래스 의 String(를 포함하여 String자체). (이 경우에는 다른 적합한 클래스 만 Object있습니다.)