如何使用RxJava 1生成斐波那契数列？

dependencies {
    compile 'io.reactivex:rxjava:1.3.8'
}

Observable<Long> fibonacciObservable = Observable.create(new Observable.OnSubscribe<Long>() {
    @Override
    public void call(Subscriber<? super Long> subscriber) {
        long prev = 0;
        long curr = 1;
        subscriber.onNext(prev);
        subscriber.onNext(curr);

        while (!subscriber.isUnsubscribed()) {
            long next = prev + curr;
            subscriber.onNext(next);
            prev = curr;
            curr = next;
        }
    }
});

fibonacciObservable.subscribe(new Subscriber<Long>() {
    @Override
    public void onNext(Long number) {
        // 处理每个生成的斐波那契数列元素
        System.out.println(number);
    }

    @Override
    public void onCompleted() {
        // 当所有元素都生成完毕时调用
    }

    @Override
    public void onError(Throwable e) {
        // 当发生错误时调用
    }
});