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

Question

斐波那契只是下一个元素依赖于前一个元素的更一般问题的一个方便示例。 https://github.com/ReactiveX/RxJava/wiki/Problem-Solving-Examples-in-RxJava 提供了一些不错的方法，但它们仍然有点老套。 generate() 也是推荐的，但在 RxJava 1 中不可用。

有什么替代方法可以做到这一点？是否有等效于 generate() ？

Answer 1

        final int number = 9;
        // [0,] 1, 1, 2, 3, 5, 8, 13, 21, 34
        final Observable<Integer> fibonacci = Observable.just(0).repeat().scan(new Pair<Integer, Integer>(0, 1), new Func2<Pair<Integer, Integer>, Integer, Pair<Integer, Integer>>() {
            @Override
            public Pair<Integer, Integer> call(Pair<Integer, Integer> pair, Integer integer) {
//                Log.d(String.format("pair: %s, int: %s", pair, integer));
                int lhs = pair.getValue();
                int rhs = pair.getKey() + lhs;
                return new Pair<Integer, Integer>(lhs, rhs);
            }
        }).map(new Func1<Pair<Integer, Integer>, Integer>() {
            @Override
            public Integer call(Pair<Integer, Integer> pair) {
//                Log.d(String.format("map: %s", pair));
                return pair.getValue();
            }
        });
        final List<Integer> result = fibonacci.take(number).toList().toBlocking().single();
        Log.d(String.format("%s", result));