我需要使用id来下载用户的数据。但是，当我稍后收到相同的用户id时，我需要取消旧的订阅(当未完成时)，并订阅新的可观察对象。我需要为每个id使用switchMap运算符，但switchMap仅用于一个值。我想同时下载所有用户的数据(并发)- flatMap。
浏览 1提问于2018-01-21得票数 1
回答已采纳
TL;DR我正在制作一个有点复杂的流--结合了flatMap和switchMap --类似于RxKotlin (RxJava 3)： .flatMapMaybe {Maybe.never() procedureMiddle
浏览 6提问于2022-02-24得票数 0
有人，请解释一下SwitchMap和FlatMap在Javascript上的区别(从角度上看，rxjs 5)。SwitchMap只发布最新的可观测值，并取消以前的可观测值。flatMap收集所有单个可观测数据，并在一个数组中返回所有可观测数据，而不关心可观测的顺序。异步工作。是那么回事吗？
浏览 5提问于2018-04-06得票数 112
回答已采纳
3回答
使用RxJS重新编写代码的更好方法是什么？ //as I need it multiple times return res .switchMap
浏览 3提问于2017-05-06得票数 1
回答已采纳
使用RxJava，我有一个Observable<A>和一个Observable<B>。我希望在B的第一个元素(也是唯一的)元素发出之后，立即开始在A上进行订阅。
浏览 2提问于2015-05-13得票数 3
回答已采纳
我正在尝试使用bindNodeCallback和fs readdir、stat读取文件。} from "fs";import { catchError, filter, flatMap, map, mergeMap, switchMap, tap } from 'rxjs/operators';
const readDirBindCall
浏览 0提问于2020-05-11得票数 1
回答已采纳
1回答
角2-链接http请求
、、、
我得到了一个RxJS，它是从httpService上观察到的，这是来自角度的实际http。现在，一旦我得到一个正的结果，我想要处理下一个http请求，我从this.retrieve()得到。这或多或少是连接请求。有更好的方法吗？ .map(data => { this.retrieve().subscribe();});
浏览 4提问于2017-03-06得票数 16
回答已采纳
1回答
我使用的是一个“ping”我的服务器并返回响应时间的服务。然后我将其显示在一个图表中。我试着在这篇文章中使用答案： .switchMap((INTVL) => { return Observable.interval(INTVLNTWDATA.datasets[0].data.splice(0, 0, this.ping); }
浏览 10提问于2016-08-15得票数 1
回答已采纳
1回答
我在发送多个操作时遇到了以下问题： someEffect$ = this.actions$.pipe( mergeMap( return this.authService.getProfile(action.payload.authInfo).pipe(
if (response.isErro
浏览 5提问于2019-10-21得票数 1
回答已采纳
我有替代的解决方案，但更像是在删除重复、过滤和转换对象数组时使用更多的非rxjs函数。 flatMap(searchCol => searchCol), (column: columnstoArray() 因此，如果没有在toArray中使用take，还是会有很好的不同的新方法。我需要类似的解决方案，在另一个地方，那里的处理可观察将
浏览 0提问于2018-12-27得票数 1
回答已采纳
2回答
这些库使用不同的API (一些承诺，一些回调)，所以如果我能弄清楚如何实现这一点，使用可观察性可能会简化API。使用rxjs，我试图找出正确的语法，这是我到目前为止一直尝试的：const { download } = require('.根据当前的评论和答案进行编辑，这是更新的，但它仍然没有将download的输出传递给transform。Rx.Observable.bindCallback(download);
const trans
浏览 0提问于2018-03-25得票数 0
我看过concatMap，但我不知道如何在第二个请求或第三个请求中使用第一个响应 concatMap
浏览 1提问于2019-08-01得票数 0
回答已采纳
1回答
使用RxJava操作，如果上游发出新的项目，是否有可能“忽略”下游处理过的元素？例如 .flatMap(...) // 30 seconds to process (Asynchronous)
.flatMap(...) //
浏览 0提问于2018-04-26得票数 0
回答已采纳
2回答
我使用RxJS事件流和fetch API发出两个连续的HTTP请求，其中第一个请求的结果必须传递给第二个请求。flatMap )。在我上面有switchMap的地方，flatMap也会工作(返回一个值)，而map，会让我(在最后的订阅中)得到一个解析的承诺。控制台显示了[[PromsieStatus]]: "resolved"和[[PromiseValue]]: /* the correct object */，但是我真的看不到像rxjs
浏览 1提问于2019-12-16得票数 2
refCount();
.do((e) => console.log("new event: " + e))
.switchMap我知道我可以通过使用publishReplay + refcount来修复这个问题(参见下面的内容)，但是在这个简单的例子中，这是可行的。我真正想要实现的是，两个组件使用相同的http调用响应，每个组件发出一个onInit事件，然后是switchMapped到http响应。我不想让每一个新
浏览 0提问于2018-01-26得票数 2
2回答
flatMap(number -> subject2).我理解为什么会发生这种情况--因为每次调用flatMap时，都会向subject2中添加新的订阅者。
问题是-如何避免这种情况？
浏览 17提问于2016-07-28得票数 1
我对RxJs和NgRx store非常陌生，我想创建一个@Effect，它结合了两个可观测值(很难解释)：export interface ProductDetails { .ofType(ProductActions.GET_STEP) .flatMap我试过使用zip，switchMap等等，但是没有机
浏览 4提问于2017-03-15得票数 4
回答已采纳
我对角4和Observables以及所有与它相关的东西都很陌生。我试图一个接一个地执行两个http请求(只有当第一个成功时，才会执行请求)。
浏览 4提问于2017-08-28得票数 6
回答已采纳
2回答
我想请求一个API，直到得到我想要的结果和请求之间的间隔。我使用两个嵌套服务(GiftsService和ApiService)：import { Injectable } from '@angular/core';})我是怎么做到的 .switchMap(data => data.status !.
浏览 1提问于2017-03-21得票数 2
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号