RXJAVA-Maybe

RXJAVA-Maybe

Maybe是Single和Completable的结合，需要注意的是onSuccess和onComplete方法只会执行其中一个，这不同于Observable和Flowable最后是以onComplete()结尾. package com.netty.demo.vertx; import io.reactivex.*; import io.reactivex.disposables.Disposable; import io.reactivex.schedulers.Schedulers; import lombok.extern.slf4j.Slf4j; @Slf4j public class RxJavaTest { public static void main(String[] args) throws InterruptedException { Maybe.create(new MaybeOnSubscribe() { @Override public void subscribe(MaybeEmitter e) throws Exception { log.info("start send data"); //onSuccess和onComplete只会发送一个 //哪个在前哪个先发送，后续的不会在发送 e.onComplete(); e.onSuccess(true); } }).subscribeOn(Schedulers.io()) .observeOn(Schedulers.newThread()) .subscribe(new MaybeObserver() { @Override public void onSubscribe(Disposable d) { log.info("onSubscribe"); } @Override public void onSuccess(Boolean aBoolean) { log.info("onSuccess:" + aBoolean); } @Override public void onError(Throwable e) { log.error("onError:", e); } @Override public void onComplete() { log.info("onComplete"); } }); Thread.sleep(300000000); } }

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。