RXJAVA-Completable

RXJAVA-Completable

Completable 不会发射数据，只会给下游发送一个信号。回调 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 { Completable.create(new CompletableOnSubscribe() { @Override public void subscribe(CompletableEmitter e) throws Exception { log.info("start send data"); //不发送数据，只发送一个完成信号或者异常信息 e.onComplete(); //e.onError(new RuntimeException("exec")); } }).observeOn(Schedulers.newThread()) //发布者线程 .subscribeOn(Schedulers.io())//订阅者线程 .subscribe(new CompletableObserver(){ @Override public void onSubscribe(Disposable d) { log.info("onSubscribe"); } @Override public void onComplete() { log.info("onComplete"); } @Override public void onError(Throwable e) { log.error("onError:" + e); } }); Thread.sleep(300000000); } }

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