文章目录

  1. 1. 源代码


微信公众号

今天,我们开始 RxJava 2.x 的入门之旅。首先,引入 RxJava 2.x 相关的类库。

<dependency>
    <groupId>io.reactivex.rxjava2</groupId>
    <artifactId>rxjava</artifactId>
    <version>2.1.16</version>
</dependency>

紧接着,我们需要写一个 Hello World 的小程序。

public class ObservableDemo {
    public static void main(String[] args) {
        Observable<String> observable = Observable.create(emitter -> {
            emitter.onNext("Hello World");
            emitter.onComplete();
        });

        Observer<String> observer = new Observer<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                System.out.println("Observer.onSubscribe");
            }
            @Override
            public void onNext(String s) {
                System.out.println("Observer.onNext: " + s);
            }
            @Override
            public void onError(Throwable e) {
                System.out.println("Observer.onError");
            }
            @Override
            public void onComplete() {
                System.out.println("Observer.onComplete");
            }
        };

        observable.subscribe(observer);
    }
}

至此,我们完成了一个简单的 Rxjava 的示例代码。运行程序,控制台会输出,如下内容。

Observer.onSubscribe
Observer.onNext: Hello World
Observer.onComplete

好的,之后,笔者会在接下来的系列文章中详细介绍 RxJava 2.x 的使用细节。

源代码

相关示例完整代码: https://github.com/lianggzone/reactive-samples

文章目录

  1. 1. 源代码