RxJava

network개발 2017. 7. 21. 11:48

(RxJava는 비동기와 multi-thread 주목적이므로 network개발로 분류) 기초:REF

데이타\처리	Completable	Maybe	Single	Observable	Subject(외부에서 데이타주입가능)
Nothing	O
One		O	O	O	O
More				O	O
Unlimited				O	O

<Observable과 Maybe 많이쓸만한 함수: 주로 양쪽에 다 존재>

Observable.subscribe ( Observer 또는 Consumer )
Observer는 { onComplete(), onError(), + onNext(), onSubscribe() }

Observable.subscribeOn (데이터주입 Schedule쓰레드)

Observable.observeOn (데이터처리 Schedule쓰레드)

.onSubscribe (Cosumer<Disposable {dispose()} >

(static).defer (Callable supplier ) : .create대신의 공급자. REF

Flowable.doOnSubscribe ( Consumer<Subscription {cancel(),request(r) } } org.reactivestreams?.Subscription

FlowableOnSubscribe inteface도 존재.

Maybe.doOnSuccess( Consumer

.doOnComplete ( Action ) , .doOnSubscribe( Action

.doOnError (Consumer

.onErrorComplete ( Predicate
.timeout ( , , Scheduler )

(static) .defer ( Callable supplier) : 공급자 (in study)

(static) .just ( T )
(static) .error(E)

Scheduler & Scheduler.Worker(하나의 thread에서 순차적으로 처리하는 Scheduler)

 ExecutorService exec = Executors.newSingleThreadedExecutor();
                                 .newFixedThreadPool(5)//cpu+1 
 try {
     Scheduler scheduler = Schedulers.from(exec);//parallelization에 최적.
                                     .computation();//cpu+1 계산에적합
                                     .io(); //cache도 해줌.cpu+1
                                     .newThread()//간단
     Flowable.just(1)
        .subscribeOn(scheduler)
        .observeOn(Schedulers.computation())
        .map(v -> v + 1)
        .subscribe(System.out::println); //blockingSubscribe(System.out::println);
 } finally {
     exec.shutdown();
 }

Maybe와 Single의 차이는 complete의 존재여부? (from REF)

Flowable : item emit속도( reactive dataflow)가 조절 가능.