我有以下可观察到的rxjs： export interface SubExperimentData { name: string;我使用以下代码从一个实验中获取所有子实验数据。 choosedExperiment包含我想要获得的子实验的选定实验。this.subexperimentData.pipe(map((extractedSResult) => {
extractedSResult.red
浏览 11提问于2021-10-20得票数 0
回答已采纳
1回答
我有一个API调用，我想用可观察到的方式包装它： final Observablereturn Observable.from(accounts); });
如何使用可观察到的我需要处理帐户流，并从中提取不同的数据集。
浏览 2提问于2015-03-26得票数 2
回答已采纳
我有一个usecase，我将一些全局变量初始化为完全变量，在链的下一步(使用andThen操作符)中，我使用这些变量。这意味着，当mUser运算符开始时，我希望andThen会被初始化。以下是我订阅的可观察到的 .subscribe(s -> Log.d(TAG, "success: " + s),根据andThen<em
浏览 2提问于2018-02-05得票数 28
回答已采纳
2回答
角异步管道再订阅
、、、
我对角异步管道的理解是，它订阅了HTML模板中可观察到的公开对象。this.http.get<Array<Todos>>(...)}<div *ngFor="let todo of todos$ | async"></div>next(value)
comp
浏览 1提问于2020-03-13得票数 1
回答已采纳
1回答
.};function getToc(data) {subscriptionNorm = collectionData(query, "id")但是当我使用这和溪流的尽头有关，但是.但我不明白RxFire / RxJs如何处理流存储查询结果：s
浏览 2提问于2020-09-17得票数 1
回答已采纳
2回答
与多个订阅者一起调用部分流？
、、、、
我有用于套接字通信的自定义Rx适配器。在它之外，我观察到消息是可流动的。然后我有一个管理器来处理每条消息，然后进一步发出它。.doOnNext{ }
然后我有两个订阅者执行我想要找到的方式，其中的一部分流将是常见的每一个订户。不幸的是，.share()操作符在observeSocket()结尾处不能工
浏览 1提问于2017-10-12得票数 0
回答已采纳
我的问题类似于这个，但我和rxjs6在angular6上，我猜一切都改变了;)在ng组件中，我可能有以下方法调用this.dataStreamService.execCall({ method : 'order_list',paramsreturn throwError(err);
浏览 8提问于2018-08-29得票数 3
回答已采纳
我正在尝试从一个服务调用map，但得到一个错误。看看，它说为了订阅，我们需要从运算符内部返回。我也有返回语句。下面是我的代码： return this.service .map( return false; ) return e;
浏览 334提问于2017-04-22得票数 91
3回答
我试图在Observable<Recipe[]>上使用RxJS管道操作符来调用我的数据上的reduce操作符，但我无法让它工作？在我的Observable<Recipe[]>中，reduce运算符不会遍历它们下面是我的尝试： .pipe(
reduce以下是作为订阅的一部分执行<
浏览 0提问于2018-05-03得票数 5
回答已采纳
现在我在ngOnInit()上一次调用一个函数，但我正在寻找一种更简洁的方式来调用所有4个函数(GET HTTP Requests)，以便它们显示旋转...都是并行的..。然后关闭微调器并处理任何错误。这是一个使用angular 7的项目。
浏览 28提问于2021-07-20得票数 0
回答已采纳
我在rxjava或rxandroid中是新手，我正在寻找一种处理多个请求的更好方法。我需要从服务器获取令牌，并使用结果作为参数进行登录验证，如果它返回成功，则通过sessionId方法获得getSessionId。我已经考虑过拉链或合并，但我不认为它会起作用。这是我的密码： api.newToken()
.subscribeOn
浏览 0提问于2015-04-04得票数 2
回答已采纳
在的错误处理部分，我阅读并理解了以下说明:即使通过错误处理操作符处理错误，原始序列也会终止。有没有一种方法来处理错误，比如流中的错误被一个值替换，并且原始序列继续？在学习错误处理运算符之前，必须记住反应序列中的任何错误都是终止事件。即使使用错误处理运算符，它也不允许原始序列继续，而是将onError信号转换为新
浏览 0提问于2017-06-06得票数 0
1回答
这里是这样的情况，我有一个使用Retrofit的API调用，该调用可能由于网络错误而失败。如果失败，我们将显示一个带有重试按钮的错误消息。当用户按下重试按钮时，我们需要重新尝试最新的可观察到的。可能的解决办法：
重试:在订阅可观察到的内容之前应该使用Retry，如果出现错误，它将立即重新订阅，这是我不想要<
浏览 15提问于2015-06-15得票数 9
回答已采纳
我已经尝试过用RxJava进行改装的https请求需要帮助才能找到好的解决方案
浏览 1提问于2019-11-25得票数 1
回答已采纳
1回答
我正在使用concat运算符连接RX观察值。我还使用重试操作符在出现任何错误的情况下重试。但是，我想在重试时跳过源代码中的一些观察值。有可能吗？Observable-A, Observable-C
).retry(ERROR); 例如，如果Observable-A完成，但Observable-B产生错误，那么在重试时，我只想重新订阅Observable-B
浏览 14提问于2019-05-03得票数 1
当最后一个主题观察者从主题中取消订阅时，AsyncSubject变得可观察。这是
subject.subscribe((v) => {});
在RxJS 5中，运算符share(
浏览 2提问于2017-07-14得票数 4
回答已采纳
2回答
我在Angular的demo.ts文件的构造器中调用这2个函数this.fetchTables()；this.fetchAllTables()；。 两者都是get api调用。在这两个调用中，每次都有一个调用失败。有时我会得到fetchTables的结果。有时我会得到fetchallTables的结果。
浏览 29提问于2018-12-21得票数 0
1回答
/ 1 / 2这是因为一旦传递错误通知，retry运算符(与所有重试运算符一样)将导致重新订阅。0
在传递错误通知时，重新订阅过程应该在流中包含错误项(在同一项上重试)--因为错误是外部的，而不是嵌入到处理的项中(因此，重新处理将有意义)。这是一个外部错误(如数据库连接)的
浏览 4提问于2015-12-03得票数 3
回答已采纳
1回答
我正在使用以下代码创建一个观察值： return Observable.createLOG.error("Error from volume observable", e); });一切正常，但我有一些关于错误处理的问题如果我理解正确的话，这应该被看作是“热可观察性”，也就是说
浏览 0提问于2017-04-11得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
