作者:小熊维尼-b晴 | 来源:互联网 | 2023-09-09 14:55
Completable不会发射数据,只会给下游发送一个信号。回调onComplete方法。packagecom.netty.demo.vertx;importio.
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() {@Overridepublic 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(){@Overridepublic void onSubscribe(Disposable d) {log.info("onSubscribe");}@Overridepublic void onComplete() {log.info("onComplete");}@Overridepublic void onError(Throwable e) {log.error("onError:" + e);}});Thread.sleep(300000000);}
}