onError java.lang.NullPointerException: 尝试在空对象引用上调用虚方法 'double java.lang.Double.doubleValue()'

Question

我已经编写了以下代码来查找 pageCount 的漫画，这些漫画在某些预算内。

起初我试图想出具有如下架构的代码：

Stream 给出了 MarvelComic 对象的价格。
我将流中的 MarvelComic 对象的价格与流中的先前漫画的价格相加，并检查它是否 < BUDGET
如果是，那么我将 MarvelComic 对象的 pageCount 与前一个 MarvelComic[ 的 pageCount 总和相加=58=] 顺流而下的对象。

如果是，则调用订阅者的onNext

由于我无法设计出一种方法来编写上述步骤中提到的代码，因此我求助于将命令式编程与响应式编程相结合。结果我写了下面的代码：

Observable.fromIterable(getMarvelComicsList()). map(new Function<MarvelComic, HashMap<String, Double>>() { @Override public HashMap<String, Double> apply(@NonNull MarvelComic marvelComic) throws Exception { HashMap<String, Double> map = new HashMap<String, Double>(); map.put("price", Double.valueOf(marvelComic.getPrice())); map.put("pageCount", Double.valueOf(marvelComic.getPageCount())); map.put("comicCount", Double.valueOf(marvelComic.getPageCount())); return map; } }) .scan(new HashMap<String, Double>(), new BiFunction<HashMap<String, Double>, HashMap<String, Double>, HashMap<String, Double>>() { @Override public HashMap<String, Double> apply(@NonNull HashMap<String, Double> inputMap, @NonNull HashMap<String, Double> newValueMap) throws Exception { double sum = inputMap.get("price")+newValueMap.get("price"); double count = inputMap.get("pageCount")+newValueMap.get("pageCount"); double comicCount = inputMap.get("comicCount")+newValueMap.get("comicCount"); HashMap<String, Double> map = new HashMap<String, Double>(); map.put("price", sum); map.put("pageCount", count); map.put("comicCount", comicCount); return map; } }) .takeWhile(new Predicate<HashMap<String, Double>>() { @Override public boolean test(@NonNull HashMap<String, Double> stringDoubleHashMap) throws Exception { return stringDoubleHashMap.get("price") < budget; } }) .subscribe(new DisposableObserver<HashMap<String, Double>>() { @Override public void onNext(HashMap<String, Double> stringDoubleHashMap) { double sum = stringDoubleHashMap.get("price"); double pageCount = stringDoubleHashMap.get("pageCount"); double comicCount = stringDoubleHashMap.get("comicCount"); Timber.e("sum %s pageCount %s ComicCount: %s", sum, pageCount, comicCount); } @Override public void onError(Throwable e) { Timber.e("onError %s", e.fillInStackTrace()); } @Override public void onComplete() { Timber.e("onComplete"); } });

我的预订：

每次在 map(), scan() 中创建一个新的 Hashmap 是个好主意吗？

如何进一步改进此代码？

问题：

此代码在 onError 中给出 NullPointerException，因为 map.get("price") returns 在 scan() 中为 null。我不太确定原因。

错误：

onError java.lang.NullPointerException: Attempt to invoke virtual method 'double java.lang.Double.doubleValue()' on a null object reference

注意：

HashMap 不为空，双字段由于某种原因被返回为空。我在想办法。

Answer 1

我认为您可以获得 getPrice(),getPageCount() 方法的空值或空白值

 map.put("price", Double.valueOf(marvelComic.getPrice()));
                            map.put("pageCount", Double.valueOf(marvelComic.getPageCount()));
                            map.put("comicCount", Double.valueOf(marvelComic.getPageCount()));

或者你可以使用Double.parseDouble();方法

Answer 2

你在这里使用了 3 次 doubleValue() 函数，

map.put("price", Double.valueOf(marvelComic.getPrice()));
map.put("pageCount", Double.valueOf(marvelComic.getPageCount()));
map.put("comicCount", Double.valueOf(marvelComic.getPageCount()));

确认marvelComic具有价格和页数[=29=的值], 我认为你在添加 pageCount[=30 时缺少 comicCount =] 作为 comicCount 在 map,

我建议使用 try catch 并打印错误以了解根本原因

Answer 3

由于

，问题可能是您的初始地图为空

.scan(new HashMap<String, Double>(), ...)

并且当第一个真实地图从上游到达时，您正在尝试从那个空的初始地图中获取值：

double sum = inputMap.get("price")+newValueMap.get("price");

我假设您想通过使用 scan 对属性进行运行聚合，因此您应该尝试 scan(BiFunction) 按原样发出第一个上游值，然后开始将之前的值与新的上游值相结合。

或者，您可以使用默认值预初始化 new HashMap<>() 并避免 NPE：

HashMap<String, Double> initialMap = new HashMap<String, Double>();
initialMap.put("price", 0.0d);
initialMap.put("pageCount", 0.0d);
initialMap.put("comicCount", 0.0d);

Observable.fromIterable(getMarvelComicsList()).
            map(new Function<MarvelComic, HashMap<String, Double>>() {
                @Override
                public HashMap<String, Double> apply(@NonNull MarvelComic marvelComic) {
                    HashMap<String, Double> map = new HashMap<String, Double>();
                    map.put("price", Double.valueOf(marvelComic.getPrice()));
                    map.put("pageCount", Double.valueOf(marvelComic.getPageCount()));
                    map.put("comicCount", Double.valueOf(marvelComic.getPageCount()));
                    return map;
                }
            })
            .scan(initialMap, 
            new BiFunction<HashMap<String, Double>, 
                    HashMap<String, Double>, HashMap<String, Double>>() {
                @Override
                public HashMap<String, Double> apply(
                         @NonNull HashMap<String, Double> inputMap, 
                         @NonNull HashMap<String, Double> newValueMap) {
                    double sum = inputMap.get("price")+newValueMap.get("price");
                    double count = inputMap.get("pageCount")
                        +newValueMap.get("pageCount");
                    double comicCount = inputMap.get("comicCount")
                        +newValueMap.get("comicCount");

                    HashMap<String, Double> map = new HashMap<String, Double>();
                    map.put("price", sum);
                    map.put("pageCount", count);
                    map.put("comicCount", comicCount);

                    return map;
                }
            })
            // etc.

Answer 4

我尝试用另一种方法解决您的问题，该方法不会抛出任何 NPE。

请不要使用 HashMap 作为数据结构。正在发生的事情是不透明的。您应该创建有意义的类。

此外，订阅者不应执行任何业务逻辑。订阅者实际上应该只使用结果并做一些副作用，比如改变视图。

我希望我没有正确理解你的问题。

@Test
void name() {
    ArrayList<MarvelComic> marvelComics = Lists.newArrayList(new MarvelComic(10, 200), new MarvelComic(3, 133), new MarvelComic(5, 555), new MarvelComic(32, 392));

    final double BUDGET = 20.0;

    Observable<Result> resultObservable = Observable.fromIterable(marvelComics)
            .scan(Result.IDENTITY, (result, marvelComic) -> {
                double priceSum = result.sumPrice + marvelComic.getPrice();

                if (priceSum <= BUDGET) {
                    int pageCount = result.sumPageCount + marvelComic.getPageCount();
                    int comicCount = result.comicCount + 1;
                    return new Result(pageCount, priceSum, comicCount);
                }

                return Result.IDENTITY;
            })
            .skip(1) // because first Value would be Result.IDENTITY
            .takeWhile(result -> result != Result.IDENTITY);

    TestObserver<Result> test = resultObservable.test().assertValueCount(3);

    Result result1 = test.values()
            .stream()
            .reduce((result, result2) -> result2)
            .get();

    assertThat(result1.comicCount).isEqualTo(3);
    assertThat(result1.sumPageCount).isEqualTo(888);
    assertThat(result1.sumPrice).isEqualTo(18);
}

class MarvelComic {
    private final double price;
    private final int pageCount;

    MarvelComic(double price, int pageCount) {
        this.price = price;
        this.pageCount = pageCount;
    }

    public double getPrice() {
        return price;
    }

    public int getPageCount() {
        return pageCount;
    }
}

static class Result {
    private final int sumPageCount;

    private final double sumPrice;

    private final int comicCount;

    Result(int sumPageCount, double sumPrice, int comicCount) {
        this.sumPageCount = sumPageCount;
        this.sumPrice = sumPrice;
        this.comicCount = comicCount;
    }

    static Result IDENTITY = new Result(0, 0, 0);
}

onError java.lang.NullPointerException: 尝试在空对象引用上调用虚方法 'double java.lang.Double.doubleValue()'

onError java.lang.NullPointerException: Attempt to invoke virtual method 'double java.lang.Double.doubleValue()' on a null object reference

java

android

observable

rx-java

rx-android