通过传递导致错误的值进行可观察的flatMap转换错误处理

文章/答案/技术大牛

发布

1回答

angular、rxjs、angular2-observables

第一步是强制的(如果失败，整个过程应该返回一个错误)，第二步是可选的(如果失败，只返回一条id为的记录)。not-working implementation: this.getMemberId().pipe( flatMap} 我想"flatMap“对我来说是正确的转换，因为我正在尝试将成员id转换为完整的</

浏览 7提问于2019-06-25得票数 0

回答已采纳

1回答

我是RxJava的新手，我通过一些样本来学习。我做了一个示例RxJava Retrofit应用程序，它将显示的电影细节。我的问题是，每当发生错误时，在onError之后，可观察到的编辑文本不再会发出任何内容。因此，基本上，如果一个电影搜索失败，因为任何API错误，我需要关闭和重新启动应用程序，以继续电影搜索。即使在onError之后，我怎样才能观察到编辑文本的变化？下面是我的代码： public c

浏览 1提问于2017-08-21得票数 1

回答已采纳

1回答

当Observable.just()没有完成时，RxJava take(1)完成了

android、rx-java2、rxandroidble

我使用establishConnection来获取连接可观察值，并希望将此可观察值转换为完备值。此代码可以正常工作，可完成代码将按预期完成： connectionObservable } .flatMap</e

浏览 19提问于2020-12-07得票数 1

回答已采纳

3回答

RxSwift映射和flatMap差异

swift、rx-swift

我无法理解RxSwift中的map和flatMap之间的区别。在RxSwift操场的例子和书籍中，flatMap被用来转换具有内部可观测性的可观测对象。然而，我看到flatMap被直接用于基本类型的Observable。例如，对于下面的代码，它们都会产生相同的输出。有人能帮我理解一下map和flatMap之间的区别吗？val.score+10)deneme.subscrib

浏览 0提问于2018-04-03得票数 12

回答已采纳

1回答

在提取请求中正确使用RxJS

react-native、rxjs

我正在尝试取一个请求到我的服务器。我想将它与RxJS一起使用，以便更好地概述我的响应数据。现在我可能在正确使用它的时候有问题..。--我在我的组件中调用RxJS fetch，在按钮单击其中我给它一些参数： var self = this; //self.props

浏览 3提问于2015-12-29得票数 0

1回答

从远程API重用RxJava流

android、rx-java

我有一个API调用，我想用可观察到的方式包装它： final Observable.startWith(realmAccounts);我用它就像 }

浏览 2提问于2015-03-26得票数 2

回答已采纳

3回答

RxJava FlatMap:如何跳过错误？

java、rx-java

在chain obs1.flatmap(x -> obs2()).subscribe(sub)中，如果obs2产生错误，则会导致立即调用sub上的onError。如文件所示：注意，如果从flatMap可以观察到的源中映射到任何单独的可观察到的项通过调用onError而中止，那么flatMap产生的可观测结果本身就会立即中止并调用onError。但是，是否

浏览 5提问于2017-02-10得票数 9

2回答

[ RxJava ]如何在Android RxJava×retrofit2上使用“`retryWhen()”来处理网络错误

android、kotlin、rx-java、retrofit2、retrywhen

我已经尝试过用RxJava进行改装的https请求需要帮助才能找到好的解决方案

浏览 1提问于2019-11-25得票数 1

回答已采纳

1回答

rxjava2生产者-消费者，‘下游’要求一个，‘上游’排放一个

rx-java、rx-android、rx-java2

我想使用rxjava2实现简单的生产者-消费者模型，当下游请求一个，上游发出一个。 .flatMap((FunctionSystem.out.println("flatMap:"

浏览 5提问于2017-12-01得票数 0

回答已采纳

1回答

RxSwift: DB事件和不同计划的问题

ios、realm、rx-swift

使用RxSwift，我为某些列提供了一个可观察到的DB表(它跟踪待定状态)。在获得事件后，我切换到另一个schedular，将列的值设置为flatMap块中的进步状态(返回可完成的)。现在，我的问题是在DB中发生太多事件时，我的可观察到的触发器会多次触发，并且不会等待我的flatMap块完全完成。这会导致代码多次处理同一个实体

浏览 4提问于2020-09-03得票数 1

回答已采纳

1回答

使用RxJava的同步序列

rx-java、rx-java2

让我们想象一下，我有一个想要在网络上传输的数据包流：我有以下传输功能：下一个数据包列表的

浏览 5提问于2017-10-18得票数 0

2回答

Angular4 httpclient错误类型'Observable<Observable<Object>>‘不能分配给键入'Observable<boolean>’

angular、typescript

正在使用angular4 http客户端从服务器获取数据，但得到的错误为 return Observable.of(false) } 在服务器上，在保存m返回true或false.What elese之后，我需要这样做，这样我就可以通过以下方式使用上面的方法

浏览 4提问于2018-01-15得票数 0

回答已采纳

2回答

带有延迟的RetryWhen()的类型错误

rx-java2、rx-android

我跟踪，然后添加以下一行：到我的Transformer，但是它触发一个编译错误：错误:不兼容类型:无法推断类型变量R(参数不匹配；可观察到的lambda表达式中的错误返回类型不能转换为Publisher)，其中R，T是类型变量:在方法fla

浏览 0提问于2018-05-14得票数 2

回答已采纳

1回答

将Future<void>转换为可观察或可流动的RxJava

android、rx-java2、android-workmanager

如何将未来返回的空白转换为可流动或可观察的RxJava？我使用的是RxJava和AndroidX WorkManager，后者提供了返回Future<void>的API。据我所知，RxJava不处理空值，因此将立即执行NullPointerException。动机：--我想把这个未来变成一个Rx可观察/可流动的，这样我就可以在这个未来完成之后进行处理。ret

浏览 3提问于2020-12-18得票数 3

回答已采纳

1回答

RxJava2:仅当所有可观察对象都发出错误时才发出错误

java、rx-java2、reactivex

我有多个可观察对象进行网络调用，只有当所有可观察对象都发出错误时，我才需要从组合器可观察对象发出错误。如果至少有一个可观察对象完成，则应传递结果。我当前的流功能如下：.flatMap{networkObservable}我可以这样

浏览 0提问于2020-02-12得票数 0

1回答

通过自定义方法处理Angular HttpClient错误

angular

在我的应用程序中，我计划通过以下方式处理错误：

浏览 6提问于2018-02-23得票数 0

1回答

即使RxJava存在，onError也会崩溃

android、kotlin、rx-java

我正在尝试调试Android上的崩溃，当设备没有网络连接时就会发生崩溃。事故有时只发生(大约50%的时间)，我不知道为什么。如果有人可以解释发生了什么，或者给出一个解决方案，我将非常感激。下面是代码(我将其崩溃的行标为“crashes：”)： var progress = 0 } } .

浏览 0提问于2018-10-08得票数 0

回答已采纳

1回答

NestJS :拦截器-- map和catchError

node.js、typescript、express、rxjs、nestjs

}); })); return next.handle();问题： catchError(err => { })} 我如何定义一个单独的拦截器来记录两条路径

浏览 1提问于2019-07-08得票数 4

回答已采纳

2回答

“携带”值到下一个.map

rx-java

我有一个可以观察到的(主题)，它散发出一个价值。我想传递这个值来生成一个新的可观测的(通过flatMap)，但也将它传递给平台地图的操作： .flatMap(latLng -> getApiManagerInstance

浏览 2提问于2015-01-20得票数 1

回答已采纳

1回答

RxJS/可观测flatMap可以返回可观测或数组

angular、rxjs、observable、flatmap

有人能向我解释为什么.flatMap运算符可以接受返回Observable或array的函数吗？说： obs$.flatMap((data) => {

浏览 0提问于2017-07-22得票数 9

回答已采纳

点击加载更多