需要简单的map（）reduce（）示例，在没有Java 8 lambdas的Android上使用RXJava

Question

我试图在没有Java 8的Android应用程序中应用RXJava，这意味着我不能使用lambda函数。为了确保我理解基础知识，我只想看一个使用map（）和reduce（）的简单示例。

我试图实现的示例是求和作为String类型List提供的整数。我想把整件事包装在一个函数中，这个函数可以被调用来获得总和，而函数调用者不需要理解这个函数是通过函数编程实现的。

我已经实现了以下内容，但它似乎过于复杂。例如，我必须使finalSum是一个数组，因为错误：无法为最终变量赋值。

我觉得这太复杂了，因为我可能误解了函数式编程/反应式编程/函数式反应式编程/等等的一些基本概念。

public void mapReduceTest() {
    List<String> ints = new ArrayList<>();
    ints.add("10");
    ints.add("20");
    ints.add("30");

    System.out.println("finalSum[0] (should equal 60) = " + sumStringOfInts(ints));
}

public Integer sumStringOfInts(List<String> ints) {
    final Integer[] finalSum = new Integer[1];
    Observable.from(ints)
            .map(new Func1<String, Integer>() {

                @Override
                public Integer call(String s) {
                    return new Integer(s);
                }
            })
            .reduce(new Func2<Integer, Integer, Integer>() {
                @Override
                public Integer call(Integer x, Integer sum) {
                    return sum + x;
                }
            })
            .subscribe(new Action1<Integer>() {
                @Override
                public void call(Integer sum) {
                    finalSum[0] = sum;
                }
            });
    return finalSum[0];
}

有人有更简单的解决方案吗？

Answer 1

这似乎太复杂了

lambda可以帮助您编写更简洁的代码。

我不能使用lambda函数。作为一个测试，以确保我了解基本知识

在这种情况下，你会得到很多样板文件。此外，许多IDE允许您编写一个lambdas，即使是在Java 7项目中，并提供将其转换为匿名内部类的快速修复方法。

我必须做最后的决定

toBlocking（）。firstOrDefault（null）将为您获取reduce操作的结果，如果需要，将对其进行阻塞：

public Integer sumStringOfInts(List<String> ints) {
     return Observable.from(ints)
        .map(new Func1<String, Integer>() {
            @Override
            public Integer call(String s) {
                return Integer.parseInt(s);
            }
        })
        .reduce(new Func2<Integer, Integer, Integer>() {
            @Override
            public Integer call(Integer x, Integer sum) {
                return sum + x;
            }
        })
        .toBlocking()
        .firstOrDefault(null);
}

有人有更简单的解决方案吗？

您可以将reduce部分替换为MathObservable。来自RxJavaMath库的sumInt（），但这并不漂亮：

public Integer sumStringOfInts(List<String> ints) {
     return 
        MathObservable.sumInteger(
           Observable.from(ints)
           .map(new Func1<String, Integer>() {
               @Override
               public Integer call(String s) {
                   return Integer.parseInt(s);
               }
           })
        )
        .toBlocking()
        .firstOrDefault(null);
}