RXJAVA-Maybe

Posted 2022-11-27 征服.刘华强

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<Boolean>() 
            @Override
            public void subscribe(MaybeEmitter<Boolean> e) throws Exception 
                log.info("start send data");
                //onSuccess和onComplete只会发送一个
                //哪个在前哪个先发送，后续的不会在发送
                e.onComplete();
                e.onSuccess(true);
            
        ).subscribeOn(Schedulers.io())
                .observeOn(Schedulers.newThread())
                .subscribe(new MaybeObserver<Boolean>() 
                    @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);