使用switchmap和forkjoin链接观察值不能像预期的角度类型脚本rxjs那样工作
使用switchMap和forkJoin是RxJS中的两个操作符，用于处理Observable流。
- switchMap操作符：它将源Observable的每个值映射为一个新的Observable，并且只发出最新映射的Observable的值。如果在新的映射Observable发出之前，源Observable发出了一个新的值，那么前一个映射的Observable会被取消订阅。
- forkJoin操作符：它接收一个Observable数组作为参数，当所有的输入Observable都完成时，它会发出一个数组，该数组包含每个Observable发出的最后一个值。
在给定的问答内容中，使用switchMap和forkJoin链接观察值不能像预期的角度类型脚本rxjs那样工作。这可能是由于以下原因之一：
- 错误的操作符使用：根据描述，可能是switchMap和forkJoin操作符的使用方式不正确。请确保正确使用这两个操作符，并根据实际需求进行适当的调整。
- 版本兼容性问题：RxJS是一个不断发展的库，不同版本之间可能存在一些差异。请确保使用的是与描述中提到的rxjs版本相匹配的版本，并检查文档或社区资源以获取更多关于这两个操作符的信息。
- 其他代码问题：除了switchMap和forkJoin操作符之外，还可能存在其他代码问题导致预期的行为无法实现。请仔细检查代码逻辑，确保没有其他错误或遗漏。
总结：根据提供的问答内容，无法确定具体的问题和解决方案。建议进一步检查代码逻辑、版本兼容性和操作符使用，并参考相关文档和资源进行调试和解决问题。
相关·内容
我有以下代码
const mySource:Observable<Observable<any>[]>
(...)
mySource.pipe(
switchMap(arr=>forkJoin(arr));
)
其工作方式与预期一致，但是
mySource.pipe(
switchMap(forkJoin);
)
失败，错误为
REST error TypeError: You provided '0' where a stream was expected. You can provide an Observable, Promi
浏览 18提问于2021-05-19得票数 3
回答已采纳
这些都是错误：
http://d2kt888p40scfz.cloudfront.net/js/ista.js#bpiopmneeadfapifejkfpahpljkicpik Failed to load resource: net::ERR_NAME_NOT_RESOLVED
core.js:3121Angular is running in the development mode. Call enableProdMode() to enable the production mode.
http://d2xvc2nqkduarq.cloudfront.net/zr/js/adrns.j
浏览 0提问于2019-01-26得票数 0
回答已采纳
3回答
我对RxJS的可观察性很陌生，我正在尝试解决一个相当简单的用例。
在服务中，我首先进行一个http调用，返回一个项(作为一个可观察的)。该项包含一个ids数组，其中一些是重复的。对于每个不同的id，我需要调用另一个http服务(再次返回一个可观察到的)，并将其返回值添加到原始项中，而不是相应的id。这些电话应该同时发生。最后，一旦每个调用完成，我的服务应该返回一个可观察到的原始项目，现在它的子项目就位。
为了给出一个更好的想法，这就是承诺而不是可观察到的结果：
MyService() {
return HttpGetMainItem()
.then(item =>
浏览 0提问于2018-09-14得票数 3
回答已采纳
1回答
我是个角质初学者，所以我面临着挑战。如何使用RxJS在角度上与嵌套的http请求交互？
.pipe(
map((res): Collection => ({
id: res.id,
name: res.name,
description: res.description,
tracks: res.tracks.items.map(track => this.trackService.fetchTrack(track.id)) //?
})
),
)
浏览 1提问于2020-11-13得票数 0
回答已采纳
我想返回一个包含已加载图像的ClientDetails对象。 因此，检索一个可观察对象，并用另一个可观察对象修改该值，然后返回整个可观察对象。 我希望下面的代码表明我正在尝试做什么，但我知道使用RxJS操作符可以更清晰地完成它。有人知道怎么做吗？ interface ClientDetails {
team: Member[];
}
interface Member {
id: number;
image: string;
}
this.clientDetails$ = this.clientService.getClientDetails().subscribe((
浏览 17提问于2020-10-08得票数 0
我对可观察对象和rxjs的整个概念还不熟悉，所以这一点可能非常明显。但是请帮帮我，因为我非常想学习 我有一个功能，当用户点击以显示博客帖子下的评论 showComments(){
this.firestoreservice.getComments(this.job.id).subscribe( data =>{
this.comments = data //type [] of comment objects with (message,posterID,timeposted...)
})
this._showcomments = tr
浏览 20提问于2020-07-16得票数 1
回答已采纳
1回答
在管道()链中组合两个可观测到的
、、、、
我使用的是Rxjs，我想从以下模式创建一个可观察的(按顺序排列)：
从paramMap$获得params，然后.
基于参数值的，将两者(getData()：可观测，getCategories()：可观测)放在一起，然后.
从(数据、类别)创建最终对象.
代码看起来应该是：
//route = this.ActivatedRoute
let obs$ = route.paramMap.pipe(
// combineLatest() is not a pipable operator, so it shouldn't be used inside .pipe()
// also it
浏览 3提问于2020-05-06得票数 0
回答已采纳
在需要基于userid的调用之后，我尝试获取Userid和serviceId，serviceId问题是它没有将可观察到的返回到ts。
Service.ts
function getData():observable<any>{
combineLatest([
this.activeSellService.getActiveSellServiceId(),
this.authService.getUserId(),
]).subscribe(([serviceId, userId]) => {
if (serviceId&
浏览 1提问于2021-10-20得票数 1
回答已采纳
有两组可观察的(网络请求)。在第一个可观测的解决方案之后，我需要forkJoin多个可观测的。但作为回报，我得到了一个Subscriber，而不是数据。
请检查一下这把小提琴
import { forkJoin, of, timer } from "rxjs";
import { map } from "rxjs/operators";
let array = [of({ data: [1] }), of({ data: [2] })];
const init = of({ pages: 2 });
function gerData() {
const
浏览 3提问于2019-12-11得票数 1
回答已采纳
1回答
我正处于学习角度的早期阶段，我正试图把我的注意力集中在RxJS、可观察等方面。我可能在语法和概念上都有问题。
因此，这里有一个服务incidentService，它获取一系列事件并在页面上显示它们。如果incident.requirementMet属性是true，那么我希望incident.resolved属性在计时器上更新列表中的每个事件。当导航到另一个视图时，我想关闭所有订阅。
到目前为止，我一直在尝试这样做。setIncidentSubscriptons()和postIncident()方法出现了问题。
角v8.2rxjs v6.4
import { Component, OnInit,
浏览 0提问于2019-08-20得票数 0
回答已采纳
import { Injectable } from '@angular/core';
import { HttpClient } from '@angular/common/http';
import { map, mergeMap } from 'rxjs/operators';
import { forkJoin, from, Observable } from 'rxjs';
const baseUrl = 'https://hacker-news.firebaseio.com/v0/';
const t
浏览 6提问于2022-01-29得票数 0
回答已采纳
1回答
我正在尝试为公共https://pokeapi.co/编写一个API接口当试图查询一个口袋妖怪时，API并没有返回整个模型，而是返回了对子对象的url引用。 (尝试查询https://pokeapi.co/api/v2/pokemon/name) 而不是预期的 Pokemon {
id,
name,
types[ (Actual model)
{
id,
name,
otherProperties...
}
]
} 我得到了 Pokemon {
id,
name,
types[ (Reference to
浏览 36提问于2020-04-21得票数 0
回答已采纳
我有三个可观察到的，前两个可以同时执行(它们不相互依赖)，但是对于第三个响应需要两个响应。我想用rxjs / observables来解决这个问题，不使用promises，我发现了一个类似的问题-- ，但是我无法使它在我的项目中工作。
到目前为止，在我的agular项目中，我有以下几点：
this.uploadService.uploadPdf(file).subscribe(res =>{
this.responsePdf = res;
})
if (!!this.thumbnail) {
this.uploadService.uploadThumbnail(this.
浏览 1提问于2020-05-20得票数 1
回答已采纳
1回答
老实说，我是NGRX的新手，在rxjs方面的经验有限。但本质上我有类似于以下代码的代码：
@Effect()
applyFilters = this.actions$.pipe(
ofType<ApplyFilters>(MarketplaceActions.ApplyFilters),
withLatestFrom(this.marketplaceStore.select(appliedFilters),
this.marketplaceStore.select(catalogCourses)),
withLatestFrom(([action, filters, cours
浏览 3提问于2020-04-03得票数 1
回答已采纳
我有一个类型的温度，例如：
type Temperature = {
source: "Sensor A",
value: number,
}
以及这种类型的可观测发射阵列。
temperatures$:$rxjs$Observable<Array<Temperature>>
现在，我希望对每个温度对象执行一个副作用 (api调用)，并将这些调用的结果附加到对象(当所有调用都被解析时)，这样一个新的可观察到的就会发出：
type TemperatureWithResult = {
...Temperature,
result: {
浏览 1提问于2017-11-24得票数 2
回答已采纳
我一直试图用mergeMap来解决这个问题，但我不认为它是正确的。
我有一个方法getNumbers()，它的http请求返回数字列表
我有一个带有另一个方法getData()的服务，其中包含一个http请求，该请求获取给定数字的数据(可观察到的)
我需要运行第一个请求，然后对结果中的每个数字运行第二个请求。我希望所有这些都是并行的，而不是等待回应。在每一个后面运行的逻辑完全相同。
下面是我目前使用rxjs的不带的解决方案
this.getNumbers().subscribe((nums: number[]) => {
nums.forEach((num: number) =&
浏览 3提问于2021-08-23得票数 1
回答已采纳
我使用AngularFire / Firebase 9(模块)的角度12。我很难使用RxJS从存储中检索downloadURL并将其添加到集合结果的每一项中。使用下面的代码，我可以在"ZoneAwarePromise“下查看控制台中的数据，但无法通过模板看到数据。
const listCollection = collectionData(collection(this.firestore, 'lists'), {idField: 'id'});
this.lists = listCollection.pipe(take(1), map(lists =&
浏览 1提问于2021-09-24得票数 1
回答已采纳
在上传完所有文件后，我正在尝试发出POST请求。在我的网页表单中，用户可以添加许多文件来上传。我有两个API来处理我的请求。
我的fileupload有一个API，它将文件保存在数据库中并返回一个id (document )，第二个API保存文档。在调用savedossier API之前，我必须将所有文档ids添加到dossier对象中。
我用mergeMap上传文件：
const fileupload$ = from(this.attachments).pipe(
mergeMap(file => this.http.post<Attachement>(`${this.
浏览 4提问于2020-05-06得票数 0
回答已采纳
我需要能够将2 forkJoins链接在一起，因为第二组可观测数据需要第一组可观测数据的输出。
问题是，如果我在一个.pipe(map(...))中执行第二个错误处理程序，可观测到的将返回另一个可观测的，而不是解析组1，然后解析组2。这意味着我必须在订阅中有一个订阅和两个这样的独立错误处理程序。
var o = forkJoin(
a: getObservableA(),
b: getObservableB(),
c: getObservableC()
).pipe(
map( result => {
a2: processA(result
浏览 4提问于2022-06-05得票数 1
回答已采纳
我有个案子：
首先，我调用一个服务，并得到一个项目列表。(对象数组)
对于这个列表中的每一项，我调用另一个服务，它们实际上都可以并行触发。
我必须等待所有的答案。当我有了所有的答案，我就有了最后的逻辑。
现在我有了这样的东西，没有正确地使用RxJS：
this.service.readArray().subscribe((array: Object[]) => {
if (array.length > 0) {
array.forEach((item, index) => {
this.service2.readItem(item
浏览 0提问于2019-07-12得票数 3
回答已采纳
3回答
如何有效地链接RxJS可观测数据
、、、、
我知道这个问题已经在这里以不同的形式被问过几次了，但是我很难让这个问题做我想做的事情。
为了提供一些上下文，我在NodeJS中有一个文件上传服务，它将图像存储在一个临时文件夹中。然后，我有一些功能，将图像调整为常规的web大小和缩略图，然后保存到上传文件夹，然后另一个函数删除临时文件。所有这三个函数都返回可观测值。
我想要的是按顺序运行这些观测数据。
observableA().subscribe((result) => //do something here ) // Resize the photo
observableB().subscribe((result) => //d
浏览 3提问于2020-04-24得票数 1
回答已采纳
1回答
map((tasks): any => {
return tasks.map(task => ({
...task,
status: this.getStatus(task.owner, task.delegationState, task.assignee, task.id),
}));
});
我在map() rxjs操作符中调用getStatus方法
getStatus(
owner: string | null,
delegationState: string | null,
assignee: string | null,
浏览 5提问于2021-12-10得票数 0
1回答
我有一个API调用，它返回一个可观察的对象集合。对于该可观测集合中的每个对象，我需要执行另一个API调用来获得一个可观察的值。
怎样才能正确地将一个可观测的集合与一组可观测的数据合并，从而使结果成为一个可观察的集合，在这里我们可以去掉额外的数据？
I.E：(1:n) -> 1
具体
// getMarkets API response:
[ {
"data": [
{
"mkt_name": "X",
...
},
{...}, {...}, {...}
浏览 2提问于2017-12-14得票数 0
回答已采纳
3回答
我有3个依赖的Rest资源(假设是可观察的)，如下所示：
第一个可观察到的项目以用户数组的形式产生，如下所示：
getUsers(): Observable<User[]>
[
{
"id": 1,
"name": "Peter",
"surname": "Smith"
},
{
"id": 2,
"name": "John",
浏览 0提问于2018-07-06得票数 14
回答已采纳
1回答
首先，我编写了一个类似于Google表单的“表单生成器”，用于运行多种类型调查的公司内部，这些调查都是问题/回答格式的。DB设计在功能上非常类似于
(取自)
后端是用Python编写的，使用Django和Django Rest框架，前端是角9。有些问题比Google表单允许的更复杂，例如，有些问题允许多个答案，某些答案与它们有“次要问题”相关联，其他问题依赖于某些答案(即，如果不选择某个答案，则必须禁用一些问题)
由于数据库的复杂性，而且主要是由于我普遍缺乏经验，我的前端解决方案往往能够发布到API中，对我来说似乎很麻烦。插入逻辑如下：
createdSurvey_Question surv
浏览 1提问于2020-03-11得票数 0
回答已采纳
以下用例:用户可以加入0.*组。每个组都有一个ID，包含0.* posts。
我订阅了一个可观察的(获取他加入的用户的组)，这将返回一个字符串数组(组ID)。
const groupIds$ = of(['a', 'b', 'c']);
如果我只有一个，我现在会使用switchMap，并返回这个新的可观察的，并订阅它，以获得该小组的帖子。
但是我有一个数组，所以这不起作用。有没有人知道哪个RxJS运算符可以做到这一点，以获得所有组的帖子？
或者不存在这种用例的操作员，而我必须在订阅时单独这样做？
浏览 0提问于2018-11-13得票数 4
回答已采纳
我有一个类似下面的RXJS Pipeline： const logs: number[] = [1, 2, 3, 4];
const url = 'http://some-url-here.com';
const pipeline = from(logs).pipe(
switchMap(logId =>
this.callEndpoint(url, logId).pipe(map(response => response.data)),
),
);
const res = await pipeline.toPromise();
console
浏览 31提问于2020-11-23得票数 0
回答已采纳
我有一个，它返回规则列表。我希望获得规则的第一页，然后为其余的页面发出并行HTTP请求。我需要第一页知道总共有多少页。
HTTP目标:在所有请求结束后立即返回一个可观察到的来自所有页面的数据列表(而不是像现在那样动态地更新一个变量)。
当前代码：
getRules(category) {
this.http.get(`rules?page=0&size=8000&category=${category}`)
.subscribe((data: any) => {
let rulesData = [];
this.load
浏览 1提问于2020-02-02得票数 0
1回答
在下面的代码中，我使用了“订阅内部订阅”。此代码工作，但代码结构非常糟糕。我想使用rxjs(forkjoin或mergemap)重构这段代码，我不知道如何实现这一点。有人能帮我吗？任何帮助都是非常感谢的。
this.chapservice.cycle().subscribe((current) => {
this.selectedCycleId = current.ratingCycleId;
this.chapService
.getChapterEvalWithSkills(
this.activeUser.ipn,
浏览 0提问于2020-11-23得票数 2
回答已采纳
我对rxjs和rxjs非常陌生，我只是无法解决这个问题。我知道我的代码是错误的，但我不知道如何正确地写它。
我通过HTTP请求获取JSON，JSON包含数组中的数据。之后，我希望遍历JSON数据中的数组，并获取另一个HTTP的附加数据。
我查看了flatMap、switchMap等等，我无法想象在我的例子中如何组合这些命令。
谢谢你们！
到目前为止，我的守则：
checkMatches() {
this.http.get<{
message: string,
result: any}>
(BACKEND_URL + 'matche
浏览 1提问于2020-05-11得票数 1
回答已采纳
大家早上好。我是Angular2的新手，在我正在从事的一个项目中，为了从REST后端检索数据，我必须发出一些HTTP请求。
从后端，我必须获得模块的列表。每个模块都有一个或多个操作。代表这两个实体的typescript类如下
export class Module {
public name: string;
public htmlPath: string;
public actions: ModuleAction[];
constructor(data: IModule){
this.name = data.name;
th
浏览 22提问于2017-03-16得票数 1
尝试创建一个rxjs管道，它将执行以下操作:本质上，我有一个动态数量的API调用数组。每次需要进行新的API调用时，我都会将其推送到数组中。
然后，我将该数组转换为RXJS切换映射操作符的数组。(调用的顺序并不重要，只是我需要在前一次调用结束后进行一次调用，而不是在同一时间)。
最后，我尝试在管道中扩展rxjs操作符的数组：
const obsArray = [randomQuote(), getCatFacts(4), recipeSearch('oil')]
const OperatorWrap = obsArray.map((obs) => {
return r
浏览 0提问于2021-01-11得票数 0
我不是Rxjs的专家。我有下面的代码。我试图上传多个文件，对于每个文件，我希望base64转换和所有的结果在最终数组中。下面的代码不工作，finalize根本不被调用。有人能帮我解决代码的问题吗？
private validateSelectedFiles(files: FileList): void {
this.spinnerService.show();
from(files)
.pipe(
concatMap(f => this.convertFile(f)),
finalize(() => {
console.log
浏览 6提问于2022-01-21得票数 0
回答已采纳
1回答
我只是尝试学习角和RxJS (可观察)，我遇到了一些问题，链接请求的正确方式。
设想如下：
我运行请求A并得到一个包含一个对象数组的JSON对象。对于这些对象中的每个对象，我都需要执行，它反过来会返回一个包含一个对象数组的JSON对象。对于来自请求B的响应中的每个对象，都需要执行，它返回一个简单的JSON对象。现在必须存储从请求C接收到的所有对象并用信息扩展它们(信息来自请求D、E和F的答案)。只有在所有请求完成后才能显示我的应用程序的UI，在此之前，只能看到加载自旋器。
我目前的解决方案提供了所有必要的信息，但我无法找到等待所有请求完成的方法。看起来是这样的：
private fetchDa
浏览 1提问于2021-10-03得票数 1
回答已采纳
我想用paralel和merge数组执行x请求，用RXJS只在一个可以观察到的数组中观察数组？
public getMetrics(url: string): Observable<GenericMetric[]> {
const ox: Observable<GenericMetric[]>[] = [];
res.forEach(elem => {
ox.push(this.http.get<GenericMetric[]>(url));
});
return forkJoin(...ox)
浏览 3提问于2019-11-05得票数 0
回答已采纳
我有一个观察者。如果成功，我想给用户反馈，然后刷新页面上的数据。所以我所做的就是调用do操作符来获得用户反馈，然后调用forkJoin来刷新数据。问题是不能在do之后调用forkJoin，错误如下：Error:(37, 12) TS2339: Property 'forkJoin' does not exist on type 'Observable<void>'.
代码：
this.pickService.activate(event)
.do(() => this.snackBar.open(`Pick activated`, null
浏览 1提问于2018-01-11得票数 0
回答已采纳
3回答
你好，我想用rxjs实现一些有几个约束的东西，但我不能同时实现它们。
我想要达到的目标可能是这样的：
first$ ---x|
second$ ------x|
subscribe -----------x|
但我得到的是：
first$ ---x|
second$ ------x|
subscribe ---x------x
使用此代码：
const checkFirstSide$: Observable<boolean> = this.checkSide('first');
const checkOth
浏览 2提问于2021-03-11得票数 0
回答已采纳
2回答
我正在努力改进Rxjs代码中的扁平化和减少链接。
服务getAllItems()的REST调用返回以下Items[]：
[{
id: 101,
name: 'Car',
owner: 1
},
{
id: 102,
name: 'Table',
owner: 2
}]
我有另一个端点getOwnerInfo(id:number)，它提供基于“所有者”id的信息，这些信息是我想要组合的，所以最后的答案应该如下所示：
[{
id: 101,
name: 'Car',
owner: {
id: 1,
浏览 4提问于2021-11-15得票数 0
1回答
如何在角度上改变对象的值
、、、、
我有这样的服务： getLastStatus(id): Observable<string> {
let url_detail = this.apiurl + `/${id}`;
return this.http.get<any>(url_detail, this.httpOptions).pipe(
map(data => {
var status = data['data'].reduce((item, curr) => {
浏览 19提问于2021-01-04得票数 0
回答已采纳
2回答
这是我第一次使自己的可观察性，我不确定我是否做得对，因为数据没有显示当加载，我看到它在控制台，但组件不刷新.
我检索帐户的I，并请求检索帐户，然后从我刚刚创建的表中创建一个可观察的帐户[]。
账户服务：
getListFriendsNoConfirmation(): Observable<Account []> {
return this.itSMe().pipe(
switchMap((me: Account) => {
return this.post('account/friendNoConf
浏览 2提问于2022-05-29得票数 0
回答已采纳
1回答
我正在学习如何建立一个小型房地产中介作为一个宠物项目。我有一个模式的形式，用户可以添加新的房地产-基本数据和图片。首先，我想将它保存到Cloudinary，然后将urls保存到Firebase中。
我不能使它按顺序工作，而是首先使用空urls数组调用Firebase。我发现rxjs中有函数finalize()，但是它也不起作用。
CloudinaryService：
uploadImage(vals: any): Observable<any>{
return this.http
.post('https://api.cloudinary.com/v1_1/
浏览 3提问于2021-03-01得票数 0
回答已采纳
3回答
我们怎样才能把下面的电话打平。对于RxJS来说是新手，试图理解如何简化它。阅读flatMap、forkJoin、switchMap和mergeMap，没有找到正确的路径在下面集成它，也不确定在下面的场景中哪一个是最好的。
const useful = [];
a.get('abc').
subscribe((abcdatas) => {
abcdatas.forEach(abcdata => {
if(abcdata.exist) {
b.get('def').
subscribe((defdata
浏览 4提问于2020-10-13得票数 1
回答已采纳
下面是再现问题的最小代码：
import { defer, BehaviorSubject, of } from "rxjs";
import { shareReplay, switchMap } from "rxjs/operators";
const oneRandomNumber = defer(() => of(Math.floor(Math.random() * 20)));
const cache = { key: oneRandomNumber.pipe(shareReplay(1)) };
export const swr = ()
浏览 5提问于2021-03-22得票数 2
我有一个相当复杂的反应行为，我想使用RxJS来实现，但我还没有找到合适的解决方案。
在我的中可以找到的角应用程序中，我有一系列的同步、异步和并行异步执行。
首先，用户单击一个按钮，然后调用我的RxJS Subject userClick$ = new Subject<void>();。
<button (click)="model.on = !model.on; userClick$.next()"> {{ model.on ? 'Stop' : 'Start' }} </button>
然后我使用
浏览 0提问于2018-03-15得票数 1
基本上，我尝试从两个端点轮询一组参赛者的数据。我的服务中有两个方法，这两个方法使用angular http-client发出api请求并返回可观察对象。第一个方法获取一个Id数组，并返回传递的每个Id的基本参与者数据(名称、运行时间、当前检查点)的数组；第二个方法获取单个Id，并返回该参与者的每个检查点的结果数组 我有一个观察值，它是第一个服务调用的结果。然后，我对其进行管道和映射，以便可以使用该数组，然后执行标准的javascript数组映射来迭代元素。我真正被困住的一点是，对于数组中匹配条件的每个“参与者”，我需要对第二个端点进行进一步的http调用，并将得到的可观察值分配给参与者的属性
浏览 10提问于2019-06-10得票数 0
回答已采纳
3回答
将多个订阅嵌套到一个订阅中
、、、、
我发现自己在尝试设置一个非常简单的rxjs订阅流时感到困惑。将多个非相关订阅嵌套到另一个订阅中。
我在一个棱角分明的应用程序，我需要一个主题填补下一个，然后再做其他订阅。
下面是我想要实现的嵌套版本。
subject0.subscribe(a => {
this.a = a;
subject1.subscribe(x => {
// Do some stuff that require this.a to exists
});
subject2.subscribe(y => {
// Do some stu
浏览 5提问于2019-10-16得票数 6
回答已采纳
我想用正确的方式应用嵌套的可观测数据。
我必须观察到，我会使用外部可观察的反应，并在孩子身上使用它。
this.selectedSchedulings$.pipe(switchMap(actualTrips => {
return this.selectedDataByBranch$
})).subscribe(data => {
this.trainsDatasets = this.getDatasets(data);
return actualTrips
});
SelectedDataByBranch是ngrx选择器。
selectedDataByBranch$
浏览 5提问于2019-11-20得票数 0
回答已采纳
1回答
如何使用rxjs在角中嵌套api调用？
getProducts(): Observable<any> {
return this.getProductIDs().pipe(
map((respnose) =>
respnose.products.map((data) => (item: any) =>
flatMap(() => this.getProduct(item.id))
)
)
);
}
// with promises we can do so
浏览 1提问于2020-12-09得票数 0
3回答
RxJ组合http请求
、、、
我尝试在rxjs中组合两个HTTP请求来帮助组合请求，但是第二个请求的参数(accountId，userId)在第一个请求的响应中。 a = http.get<any>(...);
b = http.get<any>(... + '/' + accountId + '/' + userId})
concat(a, b).subscribe(res => {});
浏览 33提问于2019-06-15得票数 0
回答已采纳
我有这4个api调用
1. HttpService.PostAsync<any, any>(`post_update_ac_translates`)
2. HttpService.PostAsync<any, any>(`post_start_auto_ac_mapping`)
3. HttpService.PostAsync<any, any>(`get_std_leaf_ac_items`)
4. HttpService.PostAsync<any, any>(`get_all_ac_translates`)
我想按这个顺序执行
首先执行1，
浏览 1提问于2019-12-19得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
