防止 RxJava 将我的自定义异常包装到复合异常中

Question

我的任务是使用 RxJava 进行实现，并以这种方式进行保护，如果发生任何错误，它就会被包装到自定义异常中。

问题是，无论我做什么，RxJavaPlugin 都会决定将我的异常包装到 CompositeException 中，即使只有一个异常。哪个测试失败。

我已经尝试了在谷歌上可以找到的所有方法，直到实际覆盖 RxJavaPlugin 的全局错误处理程序，但它忽略了尝试的更改。

在写这篇文章时应该抛出它的函数的实现

Single<BigDecimal> summarizeConfirmedTransactions() throws SummarizationException {

        try{

            Observable<Transaction> observableTransactions = transactions.get()

                    .doOnError(throwable -> {

                        Exceptions.propagate(throwable);

                    });

            Observable<Confirmation> observableConfirmations = confirmations.get()

                    .doOnError(throwable -> {

                        Exceptions.propagate(throwable);

                    });

            return Observable.zip(observableTransactions, observableConfirmations, (t, c) -> new ConfirmableTransaction(t.transactionId, c.isConfirmed, t.value))

                    .filter(confirmableTransaction -> confirmableTransaction.isConfirmed)

                    .map(t -> t.value)

                    .reduce(BigDecimal::add)

                    .toSingle()

                    .doOnError(throwable -> {

                        Exceptions.propagate(throwable);

                    });

        }catch(Exception e)

        {

            throw new SummarizationException(e.getMessage());

        }

测试中的断言失败，因为最终抛出的异常是 CompositeException，其中包含单个异常。我需要让它成为 SummarizationException.class

非常感谢。

Answer 1

好吧，经过更多的挖掘，并在朋友的帮助下，我成功地确定了任务的意图：我应该在那里做的是：Single<BigDecimal> summarizeConfirmedTransactions() throws SummarizationException {&nbsp; Observable<Transaction> observableTransactions = transactions.get();&nbsp; Observable<Confirmation> observableConfirmations = confirmations.get();&nbsp; return Observable.zip(observableTransactions, observableConfirmations,&nbsp; &nbsp; (t, c) -> new ConfirmableTransaction(c.isConfirmed, t.value))&nbsp; &nbsp; &nbsp; .filter(confirmableTransaction -> confirmableTransaction.isConfirmed)&nbsp; &nbsp; &nbsp; .map(t -> t.value)&nbsp; &nbsp; &nbsp; .reduce(BigDecimal::add)&nbsp; &nbsp; &nbsp; .toSingle()&nbsp; &nbsp; &nbsp; .onErrorResumeNext(th -> Single.error(new SummarizationException(th.getMessage())));}TL:DR 我不应该将错误“包装”到引发的异常中，而是将它们包装到包含异常的错误响应中。

Answer 2

处理此问题的一种方法是在测试中使用 try-catch 块，解开 CompositeException，然后断言捕获的异常。fun testSummarizationException() {&nbsp; &nbsp; try {&nbsp; &nbsp; &nbsp; &nbsp; summarizeConfirmedTransactions()&nbsp; &nbsp; } catch (ex: Exception) {&nbsp; &nbsp; &nbsp; &nbsp; val customException = (ex as? CompositeException)?.exceptions?.get(0)&nbsp; &nbsp; &nbsp; &nbsp; //&nbsp; assert to make sure thrown exception is of custom type&nbsp; &nbsp; &nbsp; &nbsp; assert(customException is SummarizationException)&nbsp; &nbsp; }}这是 CompositeException 被解包以获取自定义异常的地方。val customException = (ex as?CompositeException)?.exceptions?.get(0)如果允许，异常会被类型转换为 CompositeException。如果该类型不允许强制转换，则将返回 null 并导致测试失败。