RxJava2系列：rxjava2简答使用

Posted 2022-12-16 zhangjin1120

Intellij Idea版本: 2022.1
gradle版本：gradle-7.4-bin.zip

新建java项目

导入依赖

 implementation 'io.reactivex.rxjava2:rxjava:2.0.1'

完整build.gradle代码：

plugins 
    id 'java'


group 'org.example'
version '1.0-SNAPSHOT'

repositories 
    mavenCentral()


dependencies 
    testImplementation 'org.junit.jupiter:junit-jupiter-api:5.8.1'
    testRuntimeOnly 'org.junit.jupiter:junit-jupiter-engine:5.8.1'

    // RxJava2 引用
    implementation 'io.reactivex.rxjava2:rxjava:2.0.1'


test 
    useJUnitPlatform()

测试代码：

import io.reactivex.Observable;
import io.reactivex.ObservableEmitter;
import io.reactivex.ObservableOnSubscribe;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;

public class MainTest 
    public static void main(String[] args) 
        Observable<Integer> observable = Observable.create(
                new ObservableOnSubscribe<Integer>() 
                    @Override
                    public void subscribe(ObservableEmitter<Integer> e) throws Exception 
                        e.onNext(1);
                        e.onNext(2);
                        e.onNext(3);
                        e.onNext(4);
                        e.onComplete();
                    
                );

        Observer<Integer> observer = new Observer<Integer>() 
            @Override
            public void onSubscribe(Disposable d) 
                System.out.println("onSubscribe: ");
            

            @Override
            public void onNext(Integer value) 
                System.out.println("onNext: " + value);
            

            @Override
            public void onError(Throwable e) 
                System.out.println("onError: ");
            

            @Override
            public void onComplete() 
                System.out.println("onComplete: All Done!");
            
        ;

        observable.subscribe(observer);
    

运行结果：

onSubscribe: 
onNext: 1
onNext: 2
onNext: 3
onNext: 4
onComplete: All Done!