带mergeMap的角度异步管道
是指在使用RxJS编程库中的mergeMap操作符时，通过将多个异步操作连接起来，形成一个管道，以便按顺序执行这些操作并处理它们的结果。
具体来说，mergeMap操作符将一个Observable序列转换为另一个Observable序列，并且可以同时处理多个内部Observable的结果。它接收一个回调函数作为参数，该回调函数返回一个Observable，然后将这个Observable的结果合并到输出Observable中。
在使用带mergeMap的角度异步管道时，可以实现以下功能：
- 顺序执行多个异步操作：通过将多个Observable序列连接起来，可以按照定义的顺序依次执行这些异步操作，而不需要嵌套回调或使用复杂的控制流程。
- 并行处理多个异步操作：由于mergeMap可以同时处理多个内部Observable的结果，因此可以并行执行多个异步操作，提高程序的性能和响应速度。
- 灵活地处理异步操作的结果：通过在mergeMap的回调函数中进行处理，可以对每个异步操作的结果进行灵活的转换、过滤或其他操作，以满足具体业务需求。
- 简化代码结构：使用带mergeMap的角度异步管道可以将复杂的异步操作逻辑进行模块化和组合，使代码结构更清晰、可维护性更高。
在云计算领域中，带mergeMap的角度异步管道可以应用于各种场景，例如：
- 多个异步请求的串行执行：当需要按照特定顺序执行多个异步请求时，可以使用带mergeMap的角度异步管道来实现。
- 并行处理多个数据源：当需要从多个数据源获取数据，并行处理这些数据时，可以使用带mergeMap的角度异步管道来提高处理效率。
- 复杂的数据处理流程：当需要对一组数据进行复杂的处理流程，包括数据转换、过滤、聚合等操作时，可以使用带mergeMap的角度异步管道来简化代码结构。
腾讯云提供了一系列与带mergeMap的角度异步管道相关的产品和服务，包括：
- 腾讯云函数（云函数）：腾讯云函数是一种无服务器计算服务，可以将带有mergeMap的角度异步管道作为函数逻辑进行部署和执行。详情请参考：腾讯云函数产品介绍
- 腾讯云消息队列（CMQ）：腾讯云消息队列是一种高可靠、高可用的消息队列服务，可以用于在带mergeMap的角度异步管道中进行消息的传递和处理。详情请参考：腾讯云消息队列产品介绍
- 腾讯云数据库（TencentDB）：腾讯云数据库提供了多种数据库产品，可以用于存储和管理带mergeMap的角度异步管道中的数据。详情请参考：腾讯云数据库产品介绍
请注意，以上只是腾讯云提供的一些相关产品和服务示例，实际应用中还需要根据具体需求选择适合的产品和服务。
相关·内容
2回答
getBudgetMap(budgetMonthID){
this.rows = [];
this.categoryService.getCategory(budgetMonthID).subscribe(category =>{
this.categoryList = category;
this.categoryList.forEach(category => {
this.transactionService.getTransaction(budgetMonthI
浏览 2提问于2018-10-22得票数 2
当前行为
使用我的http服务调用api以获取所有用户
对于每个用户(循环)，使用我的http服务调用api (其他实体)以获取用户的所有位置。
我需要与他的用户关联的位置(根据请求返回)。
显示一个阵列(角质材料垫-标签)
我的数组是空的或缺少每个用户对象中的位置.
预期行为
我需要建立一个数组与用户和他的位置之前打印垫标签。
带指令的问题的最小再现
在我的部分：
public userWithLocations = [];
ngOnInit () {
this.loadData();
}
loadData()
浏览 0提问于2018-08-08得票数 0
我是新的角度，我使用id过滤用户，就像在JWT有效负载中一样。
我可以在可观察到的订阅()中这样做：
this.route.data.subscribe((data) => {
this.users = data.users.filter((u: User) => u.id !== +this.authService.decodedToken.nameid);
});
我还可以在管道()方法中这样做，如：
this.route.data
.pipe(map(data => data.users.filter((u: User) => u.id !
浏览 2提问于2019-12-09得票数 1
回答已采纳
1回答
我用角度实现了动态背景图像。我就是这样做的：
<div [style.height.px]="coverHeight" [style.background-image]="'url(' + coverImage + ')'" class="card mb-3">
</div>
我这么做是因为这是一种不失真地调整图像大小的方法。效果很好。
但是，下面是一个输入，每次调用(change)函数时，我都想更新div上的图像。
因此，我有一个默认的图像，当我的用户在输入中放置类似https://s.i
浏览 0提问于2019-09-11得票数 1
回答已采纳
我的后端经常将数据作为可观察到的RxJS 5中的数组返回(我使用的是角2)。
我经常发现自己希望用RxJS操作符单独处理数组项，我这样做是用以下代码()：
const dataFromBackend = Rx.Observable.of([
{ name: 'item1', active: true },
{ name: 'item2', active: false },
{ name: 'item3', active: true }
]);
dataFromBackend
// At this point, the obs e
浏览 3提问于2017-02-27得票数 58
回答已采纳
2回答
我有一个图像，我需要在离子移动框架中使用Angular来显示。 HTML如下所示： <div class="avatar-image" [ngStyle]="{'background-image': getAssetImage(item.imageUrl)}"></div> 现有的Angular typescript如下所示： public getAssetImage(image) {
const imagepath = Constants.mediaUrl + '/' + image;
浏览 11提问于2021-06-23得票数 2
我正在Ionic 4应用程序中创建一个。我想阅读来自的。
我尝试使用mergeMap，但它总是返回一个错误：
Property 'mergeMap' does not exist on type 'Observable<any>'
以下是token.interceptor.ts的完整代码
import { HttpRequest, HttpHandler, HttpEvent, HttpInterceptor, HttpResponse, HttpErrorResponse } from '@angular/common/http';
浏览 0提问于2019-02-13得票数 1
回答已采纳
当*ngIf指令基于异步条件时，如何消除上述错误？
在我的主组件(products.ts)中，我订阅了一个可观察对象，这是用户选择的结果，用户可以通过与许多组件(包括products.ts)进行交互来进行选择。在此组件的模板(products.html)中，我需要检查是否选择了任何产品，如果是，则显示它们的编号。
这一切都工作得很完美，但我想摆脱这个错误。
Product.ts
ngOnInit() {
this.productService.getProducts().subscribe(data => {
this.products = data;
浏览 4提问于2020-01-02得票数 1
1回答
我在角度上使用Ag网格，对于rowData，我使用来自json的数据，它存储在我的assets文件夹中，我使用HttpClient读取数据。但是数据没有加载，我得到了一个错误：
TypeError:无法读取null的属性“dispose”
但是，当我试图在控制台中打印json数据时，它是正确显示的：
.ts文件是：
import { Component, OnInit } from '@angular/core';
import { HttpClient } from '@angular/common/http';
@Component({
浏览 2提问于2020-04-22得票数 0
我正在处理一个文件加密和上传类使用角。这些操作中有许多是异步的，因此我编写的方法正在返回RxJS可观测值。
// 1.
private prepareUpload(file): Observable<T>;
// 2.
private encryptData(data, filekey): Observable<T>
// 3.
private uploadEncryptedData(formData, token, range): Observable<T>
// 4.
private completeUpload(updatedFilekey, t
浏览 1提问于2019-03-29得票数 12
回答已采纳
1回答
你好，如何将有效载荷参数从mergeMap传递给switchMap？我在clientservice.checkValideName中使用它，但希望将它传递给sendMessage(data，payload1)。
我试过很多东西，但都没有用。(另一次合并或映射checkValideName的结果以注入有效载荷)
@Effect() CheckValidatedName$ = this.actions$.pipe(
ofType(CheckValidatedActionTypes.VALIDATED_NAME),
map((action: ValidatedNameAction) => a
浏览 0提问于2018-10-25得票数 0
您好，我有一个返回object的方法，我计划在最后一次成功调用后调用n多次，并将combine转换为array。
public getActivity({minprice, maxprice, type}: QueryParams) {
const url = `${BASE_URL}?minprice=${minprice}&maxprice=${maxprice}&type=${type}`;
return this.httpClient.get(url);
}
我真的不确定如何在rxjs中做到这一点，但我的预期输出将如下所示：
activities
浏览 0提问于2019-12-16得票数 0
我试着理解，mergeMap在这个例子中是如何工作的，但仍然不理解。你能帮帮我吗?
import { interval } from 'rxjs';
import { mergeMap, take } from 'rxjs/operators';
// emit value every 1s
const source$ = interval(1000);
source$
.pipe(
mergeMap(
// project
val => interval(5000).pipe(take(2)),
//
浏览 1提问于2021-04-23得票数 0
回答已采纳
我知道，这是个相当复杂的问题，但我对RxJ的文档非常困惑.
我有一个有角度的应用程序，我正在使用OpenLibrary API创建作业作业。我有一个名为SearchService的服务，它使用/search端点。问题是，这个端点返回格式不理想的文档，因此对于每个返回的文档，我必须一个接一个地从不同的端点查询实际的对象，因为当前似乎不可能进行批处理查询(服务器只是返回HTTP 500)。
我的解决方案，目前正在工作如下：
Observable<AuthorSearchResponse>Pipe 使用/search的HttpClient查询/search端点，此函数将其返回给RxJs
浏览 1提问于2020-05-13得票数 2
回答已采纳
5回答
如何删除RXJS中的冗余请求？
、、、、
我正在使用Rxjs和进行前端项目，我想从一个api“api/ data _processor_classlib.php.”中获取json数据。其中有三个部分是在this.webProtectionHTML$上订阅管道的。我不知道为什么管道this.webProtectionHTML$提出3次请求。是否有任何可能的解决方案只发送一个请求并更新HTML中的所有数据？谢谢。
HTML代码：
<div class="tr">
<div class="align-left">Phishing & Other Frauds
浏览 2提问于2020-04-04得票数 1
回答已采纳
2回答
我是新的角，我试图提出一个http get请求，并根据它的反应，我必须打一个后端电话。
在这里，我试图链接2异步调用，不确定这是否可行/正确的角度(使用角7版本)。
问题语句：第二个(后端) aysnc调用是在从第一个(http)异步调用获得响应之前进行的。
我尝试使用异步/等待(理解不正确的方法，但仍然尝试)来实现，并在订阅第一次http调用时调用后端调用。这两种方法都行不通。请告诉我这里出了什么问题，如果有更好的方法来链接2异步调用。
下面是代码片段(简化版本)
export class BasicService{
let httpUrl:string=null;
construct
浏览 1提问于2020-05-06得票数 0
回答已采纳
在rxjs6.5中，我在类型记录/角中有这样的场景：
main(){
const properties = ['session', 'user'];
const source: Observable<any> = from(properties);
source
.pipe(
mergeMap(key => this.getKey().map((value) => ({key: key, value: value}))),
浏览 0提问于2019-04-30得票数 7
回答已采纳
我想在我的异步验证器中添加debounceTime和distinctUntilChanged。
mockAsyncValidator(): AsyncValidatorFn {
return (control: FormControl): Observable<ValidationErrors | null> => {
return control.valueChanges.pipe(
debounceTime(500),
distinctUntilChanged(),
switchMap(value =&g
浏览 0提问于2019-05-30得票数 4
回答已采纳
2回答
我很新的角度(我使用的是最新版本的cli)，并且肯定会有一个非常简单的方法来做我正在尝试的事情(非常糟糕)，任何帮助都是非常感谢的！
我们正在重建一个应用程序前端，目前我们的数据由以下端点/cars提供，并接收到：
{
"cars": ["Fiesta","Toyota", "Fiat"]
}
对于每辆车，都有另一个具有更多详细信息的端点，因此/Fiesta返回：
{
"Fiesta": [ ["model":"Sentra", "doors":4,
浏览 0提问于2018-08-02得票数 1
回答已采纳
我正在尝试使用redux-observable进行连续的API调用。第一个API调用的结果数据应该用于进行下一个API调用。This post解释了如何在Angular中使用rxjs，但我无法传递相关知识。 我已经编写了两个史诗，我想把它们组合起来： const createList: Epic = (action$) => action$.pipe(
/*
* Post a new empty list
*/
ofType(CREATE_LIST),
switchMap(({ payload }) => {
const [postData, conf
浏览 15提问于2020-08-17得票数 1
回答已采纳
1回答
我需要你的建议如何将Rxjs 5转换为Rxjs 6。
我的代码如下，我不太确定为什么它不能工作。
Rxjs 5
Observable.from([{amount:5},{amount:10}])
.flatMap(_ => depositService.deposit(depositAmount))
.toArray()
.subscribe(result => {
console.log(result.length);
})
Rxjs 6
import { Observable, from, } from 'rxjs';
import { map, cat
浏览 5提问于2018-08-14得票数 1
我有一些代码，在最近5个左右的angular版本中，这些代码对我来说工作得很完美。 一旦升级到Angular 10，它就不再在头上设置持有者标记。我在升级说明中没有看到任何关于对HTTP客户端的修改或如何工作的内容。 我的代码有没有一点小问题，现在有人不得不去处理了？ private async handleAccess(request: HttpRequest<any>, next: HttpHandler): Promise<HttpEvent<any>> {
await this.angularFireAuth.user.subscrib
浏览 11提问于2020-07-05得票数 0
回答已采纳
2回答
如何使异步函数在角？
、、、、
在componentOne.ts中，我通过sharedService发送数据，
this.sharedService.sendData(this.getCheckedProduct);
在componentTwo.ts中，我订阅的数据如下，
productList: any = [];
getAllProducts: any = [];
ngOnInit() {
this.sharedService.getData().subscribe(data => {
this.productList = data;
浏览 1提问于2018-11-27得票数 0
2回答
我的工作角度是7。
我希望在执行剩下的语句之前，等待函数完成。
在我的示例中，我希望在执行其余语句之前等待saveAttach函数：
this.router.navigate(['/pages/sending']);
当我测试我的代码时，该页将在saveAttach函数运行之前转发到发送页面。
这意味着这个语句this.router.navigate(['/pages/sending']);首先运行
然后this.dropzone.saveAttach(data.body[0].id);正在运行。
这是我的密码：
public sendTransfer()
浏览 2提问于2021-02-16得票数 0
回答已采纳
1回答
我想这个问题以前就有人问过，我试过我能找到的每一个解决办法，但都没有结果。我对RxJ有点陌生，所以如果这看起来很容易的话，我很抱歉。
考虑以下服务：
getSessionsByCampaign(campaignDBID: number) : Observable<CfgCampaignGroup[]>{
return this.http.get<CfgCampaignGroup[]>('http://localhost:4567/api/configuration/sessions?campaign=' + campaignDBID);
}
g
浏览 0提问于2018-06-08得票数 0
回答已采纳
我有输入字段，它应该建议用户名与输入字段中的文本相匹配。我正在使用ngx-引导打字机库。
用户名列表必须从运行在后端的API调用中获取。在每次击键时，它都必须调用API端点并将匹配的结果返回给我。
我试过以下方法。
service.ts
search() : any{
this.req = this.http.get('/timesheet/user').subscribe(
res => {
return res;
},
(e) => {
console.log('Error');
},
() => {
浏览 2提问于2018-01-09得票数 1
回答已采纳
我正在创建一个角度应用程序，它通过websocket连接发送和接收数据。我有一个服务SocketService，它打开并保持连接，该服务被注入到其他服务中。
websocket上的每条消息看起来都类似于{ctrl: string, payload: any}，并且为SocketService中的每个控制器(ctrl)创建了一个Subject，其他服务可以订阅这些控制器(ctrl)，因此每个服务只订阅预定给它的消息。
随着越来越多的服务和控制器的出现，我在SocketService中拥有越来越多的SocketService，现在我想知道让每个服务直接订阅websocket消息并让服务本身检查消息
浏览 4提问于2020-06-02得票数 2
回答已采纳
1回答
我有以下伪代码 zip(
...[1, 2, 3].map((id) =>
this.http.function1(id).pipe(
mergeMap((obj1) => this.http.function2(obj1.id)),
mergeMap((obj2) => this.http.function3(obj2.id)),
),
),
).subscribe((result) => {
console.log(&
浏览 12提问于2021-09-03得票数 1
回答已采纳
1回答
import { Observable } from 'rxjs/Observable';
import 'rxjs/add/observable/merge';
this.events = this.availableHoursCollection.valueChanges()
this.bla = this.afs.collection<AvailableHour>('users')
.doc('G2loKLqNQJUQIsDmzSNahlopOyk1').collection('availableH
浏览 3提问于2017-12-30得票数 0
回答已采纳
1回答
我正在尝试编写一个HTTP拦截器来为请求添加一个“访问级别”参数。我试图从一个可观察的currentAccessLevel$中获取值。但是，observable不会正确返回，拦截器会中断整个请求周期。 这个问题已经有了答案here和here，然而，公认的答案似乎在Angular 8中不起作用。我不确定我是否做错了什么，或者是否在Angular 8中对拦截器进行了某种更改。 我还尝试使用switchMap、flatMap和mergeMap。 import { Injectable } from '@angular/core';
import {
HttpRequest,
浏览 18提问于2019-09-16得票数 3
回答已采纳
我试图用flatMap链接2个订阅，但是flatMap中的"this“并不指向我的组件，而是指向MergeMapSubscriber。在运行时，_this引用我的组件，但是如果我在代码中使用它，TypeScript不会编译
import { flatMap } from 'rxjs/operators';
this.payexMasterService.queryOk().flatMap(
(res: ResponseWrapper) => {
_this.templateData.dataSets[0].data[0]
浏览 2提问于2018-02-28得票数 0
回答已采纳
如果在以下代码中发出破坏$时，takeUntil将管理mergeMap的订阅吗？换句话说，mergeMap泄露是订阅吗？
combineLatest([
this.selectedCustomerId$.pipe(
-->mergeMap<--(customerId => invoicesService.getInvoices(customerId)
),
this.configuration$
]).pipe(
takeUntil(this.destroyed$)
).subscribe([invoices, configur
浏览 1提问于2020-08-10得票数 0
回答已采纳
1回答
我有以下可观察的实现
public getFromAddressSubjectObservable() {
let _address: string;
return this.fromAddressSubject.pipe(
tap((address: string) => _address = address),
mergeMap(() => this.rpc.call('', 'smsglocalkeys', [])),
map((keys: SmsgLocalKeysResult) =&g
浏览 2提问于2020-03-04得票数 0
回答已采纳
1回答
关于下列代码：
public getExecution(modelId: string, reportId: string, params: ParameterSet | null): Observable<ExecutionToken> {
return this.getNewExecution(modelId, reportId, params, null)
.pipe(
mergeMap((token: ExecutionToken) => {
return this.reportExecutionHubSe
浏览 5提问于2022-03-15得票数 0
回答已采纳
我在Angular 8上工作，我想在Angular模板中使用带参数调用的函数，所以我使用了PipeTransform，问题是当我使用服务时，订阅之外的变量是未定义的
这是CqpPipe.pipe.ts
projectCqp :string[];
transform(value: number, args?: any) {
this.cqpservice.getNumberOfProjectPerCQP(value, "Ressource Allocation").subscribe(data => {
this.projectCqp = data;
浏览 2提问于2020-03-09得票数 1
我正试着用角度来制作我的拳头定制管道。我有一个我似乎无法解决的问题。我有一个for循环，然后应用我的自定义管道执行websocket调用，该调用应该显示关于许多元素的数据。但它只给了我一个可以观察到的模板，它是最后一个元素。所以我猜每次循环的时候它都会写得太多了。有人能帮我理解我在这里做错了什么吗？
这是我的自定义管道ts文件：
import { Pipe, PipeTransform } from '@angular/core';
import { map } from 'rxjs/operators';
import { Observable, Subjec
浏览 1提问于2022-02-15得票数 0
1回答
我正在尝试为父集合中的每个文档获取一个集合及其子集合。编辑过的 fetchNewMarkets() {
this.firestore.collection<Market>('markets', ref => {
const key = `name.ar`;
return ref.orderBy(key).where('reviewResult', '==', true);
}).snapshotChanges()
.pipe(
filter(snapsho
浏览 8提问于2020-11-09得票数 0
我有一个助手函数，它调用一个API并返回一个items数组。这些项中的每一项都表示一个实体，比如说一个User。 每个用户都有一个category_id属性，默认情况下该属性为null。我想从另一个辅助函数的结果中为每个用户填充此属性，该函数接受用户ID并返回Category对象的一个可观察对象，我可以从该对象中提取ID，并将其用作用户的category_id属性。 我已经得到了以下(伪)代码(TypeScript语法，但这个问题通常适用于可观察运算符)： this.backend
.request(
'v1/users',
)
.pipe
浏览 11提问于2019-02-26得票数 1
我想知道在进行多次mergeMap调用后是否可以输出一个数组ob observable。 下面是我想要得到的一个例子 this.kbSvc.create(kb).pipe(
map(dbKb => kb = dbKb),
mergeMap(() => this.goSvc.create(kb.id, "Build Market Share")),
mergeMap(go => this.marketSvc.create(kb.id, (<GrowthOpportunity>
浏览 17提问于2019-06-15得票数 0
1回答
所以我有一个可以观察到的，它会发射出一系列的物品。
我希望将每个项映射到一个自定义对象，但其中一个对象字段再次通过可观察性获取异步。
到目前为止，这就是我所拥有的：
const resultingObs = arrayObs
.flatMap(x => x); // map array to a stream of items
.mergeMap(item => asyncFetch(item.id)); // get async data from another stream
这很好，因为到目前为止，它将每一项映射到获取的数据，这是我试图
浏览 0提问于2018-09-19得票数 0
回答已采纳
6回答
我试图链接多个rx.js可观测值并传递数据。Flatmap应该是适当的操作符，但是它的重要意义是
import { Observable } from 'rxjs/Observable';
没有找到：
Error TS2339: Property 'flatmap' does not exist on type 'Observable<Coordinates>'
使用了5.0.0-beta.6的rx.js版本。
public getCurrentLocationAddress():Observable<String> {
浏览 5提问于2016-07-20得票数 65
回答已采纳
是否有可能在不更改为Promises的情况下等待rxjs可观察性？我正在做6个请求OnInit()，然而，一些请求在另一个请求之前完成，顺序很重要。可以在类型加密中等待可观察对象吗？所有函数看起来都一样，它们只是向服务器发出了不同的请求。感谢您的帮助:)以下是我的代码： 我设法通过链接请求来实现它(在我从前一个请求得到响应之后调用下一个请求，然而，这个解决方案效率不高，而且看起来很丑陋) ngOnInit() {
this.userId = this.auth.getUserId();
this.getTrendingRentals();
this.g
浏览 18提问于2019-01-11得票数 2
回答已采纳
我有一个问题，我从web得到一个数组作为响应。
反应的结构很简单：
interface CabinInfo {
id: number;
projectId: number;
cabinId: number;
ipAddress: string;
port: number;
}
因此，现在我需要按照projectId对其进行分组，因此自然地，我会使用rxjs/操作符来获得某种类型的d数组，我可以在html中迭代，所以我使用：
this.clientService.GetAllApplications()
.subs
浏览 0提问于2018-07-30得票数 1
回答已采纳
我正在编写使用IndexedDB缓存数据的角度应用程序。
每当应用程序要对服务器执行特定的http调用时，我都希望从IndexedDB中检索这些数据，并充实或替换来自服务器的响应。
问题是，从IndexedDB检索数据是异步操作，返回可观察到的数据，而我无法将修改后的数据返回给调用服务。
拦截器看起来是这样的：
intercept(req: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {
return next.handle(req).map((event) =>
浏览 0提问于2018-04-10得票数 4
回答已采纳
1回答
我正在尝试构建一个能够管理数据库的服务--问题是，我试图将订阅存储在服务类上，而不是组件类上，因此它们都在同一个位置--然而，据我所理解，订阅的回调需要在订阅激活时定义，在订阅激活后是否有方法添加到订阅中？我查看了.add()操作符，但这似乎只有在订阅被取消时才有效。
编辑
下面是我能想到的最好的功能；它很有效，但看起来不优雅，甚至没有最佳实践。
test(col, doc, callback) {
(this[col][doc] as Observable<unknown>) = this.afs
.collection(col)
.doc(d
浏览 1提问于2020-01-09得票数 1
回答已采纳
我想移动一个精灵(跑步者)，按下键盘的左右箭头键:这个想法是移动一个沿着直线运行的小角色，按键盘的左右键.这是下载html页面的链接: blob:
代码应该在rxjs中。
这就是我迄今为止所做的(，谢谢您的帮助，)：
<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8"/>
<title>TP RXJS</title>
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs
浏览 5提问于2020-07-02得票数 0
回答已采纳
如何以角度嵌套的方式呈现单个记录列表？我有一系列的预约记录。我想把约会按日分组。如果您自己使用Javascript中的嵌套循环生成HTML，这很简单，但我不知道如何从单个列表中使用角*ngFor (嵌套*ngFors与多个列表非常简单)。
下面是这个问题的简化版本。首先是数据模型。
export interface Appointment {
scheduled: Date;
client: string;
}
appointments$: Observable<Appointment[]>;
这里是我想要呈现它的方式，按日分组，然后是每天下面的客户名称列表。
浏览 2提问于2021-11-13得票数 0
回答已采纳
2回答
让我说，我有一个可以观察到的，能让员工发光的。
$employees
我希望根据一个可观察到的方法来操作每个员工的子属性。对于这个例子，让我们说显示名称。
目前我正在执行这样的任务。
const getDisplayName = (emp) => {}; //returns an observable
const mapFn = async (emp) => {
emp.displayName = await getDisplayName(emp).toPromise();
return emp;
}
$employees
.pipe(mergeMap
浏览 1提问于2020-04-22得票数 0
回答已采纳
我正在实现resolve方法：
resolve(route: ActivatedRouteSnapshot, state: RouterStateSnapshot): Observable<Obj> | Obj {
return this.service.get(route.params['guid'])
.map((response: Json) => {
return this.service.list(response.data.id).map((response: Json) =&
浏览 0提问于2018-10-30得票数 0
回答已采纳
1回答
我是Rxjs的新手，正在尝试编写一些代码 combineLatest( [poll$, user$ ]).subscribe( ([poll, user]) => {
this.poll = poll;
if( user.participated_in_polls.includes( poll._id )) {
this.already_participated = true;
return;
}
this.questionsService.get(
浏览 10提问于2021-04-20得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
