我正在使用ngrx在Angular中构建一个服务，用于在存储中查找消息列表。一旦有了列表，它就需要为每条消息获取一些异步数据，并定义一个新的对象(ModifiedMessage)。该服务应返回一个包含已修改消息列表的可观察值。我的尝试是： getMessages(): Observable<ModifiedMessage[]> { this.s
浏览 27提问于2019-04-05得票数 0
1回答
catchError块导致错误，因为返回类型变成Observable<Client | Client[]>。我不明白为什么它认为它不是一组客户端，也不知道如何修复。#clients: Client[] = []
headers = headers.set('If-Modified-
浏览 8提问于2021-12-21得票数 0
回答已采纳
我正在编写使用IndexedDB缓存数据的角度应用程序。intercept(req: HttpRequest<any>, next: H
浏览 0提问于2018-04-10得票数 4
回答已采纳
我有一个项目的列表，对于每个项目，我想做一个异步作业，然后更新UI。我使用rxjav来完成异步任务。我如何遍历列表并执行此操作。我试着使用Observable.FromArray，但我认为它不起作用
Observable.fromArray
浏览 2提问于2018-03-07得票数 0
我有一个项目集合，每个项目都有不同的userId值，我需要将它们分组到一个多维数组中。(itemsArray)时groupBy运算符是如何工作的，但我不知道如何将其与从AgularFire返回的Observable一起使用 .groupBy( item => item.userId ); //ite
浏览 11提问于2018-01-10得票数 0
回答已采纳
这是我的.ts： import {Observable} from 'rxjs';
myObservableArray : Observable<any[]lbs="+this.variable,{responseType: 'json'});
console.log(this.myObservable.Array) 我可以在html中看到json数组，但是我不能设法在.ts中获取对象！
浏览 34提问于2020-06-24得票数 0
我明白这是可以观察到的。第一个map函数获取要添加的书籍payload，同样由保存到数据库的mergeMap处理。原始代码： addBookToCollection$: Observable<Action> = this.actions$ .catch(() => of(new collection.
浏览 0提问于2017-04-01得票数 4
回答已采纳
使用Node.js 模块，可以按以下方式顺序调用对象数组上的函数：var，在processor函数中执行的代码可以是异步的，只有在异步任务完成后才能运行callback。这意味着dataArray中的每个对象将被一个接一个地处
浏览 2提问于2017-03-14得票数 0
2回答
我在ReactiveExtensions上遇到了麻烦(可能很难理解)，我在WinForms应用程序中连接到一个WCF服务，从下面的教程中可以看出--这是我想出来的，而且这从来没有起作用--所以我把它从常规的同步方法改为异步的方法为什么Task<T[]>.ToObservable()在我订阅它的时候给我一个T[]？我可能有更多的错误。谢谢你的帮助！
浏览 2提问于2014-05-21得票数 1
回答已采纳
我有一个角度的HttpInterceptor，我需要调用一个定义如下的加密方法：不过，我不知道如何在HttpInterceptor中处理这个问题： const modified = re
浏览 0提问于2018-12-24得票数 2
回答已采纳
我可以从数组创建observable，但它的type是Observable<number>而不是Observable<number[]> const arraySource = Observable.from([1, 2, 3, 4, 5]); constsubs
浏览 6提问于2018-02-07得票数 3
回答已采纳
, HttpParams } from "@angular/common/http" importfor (const region of regions) } }这是我订阅的组件中的代码> {
浏览 44提问于2018-06-08得票数 3
回答已采纳
我有时需要一次更新许多文档，10K甚至更多，我在想每种方式的优点/缺点是什么？我正在寻找一个好的批量方式来做到这一点。方法1，发送到observable，获取所有文档并完成工作： .from(ids) return bucket.
浏览 1提问于2015-02-25得票数 1
1)有没有更好的方法来实现我的集合的异步？ }
{ o => Observable.To
浏览 2提问于2011-02-21得票数 3
回答已采纳
3回答
我想返回一个对象的可观察值，该对象是从我的存储中选择的对象数组中选择的。我想使用.single运算符，因为如果存在少于或多于1个对象，则会抛出异常。我不能让它工作，因为我的存储返回的是一个数组而不是一个可观察对象。我知道我可以在阵列上使用.filter，但我想知道为什么我不能让它工作。我甚至尝试过使用选择器。中尝试这样的东西： const editId
浏览 0提问于2017-11-08得票数 2
1回答
我在Ionic应用程序中遇到了一些问题(数据异步更新，但UI没有相应更新)。我在这个问题上花了很长时间，现在正在尝试一种不同的方法:使用Observables。但我不知道该如何实施。getter，它将返回Person[]列表的Observable。我不知道的是：
如何在何处为列表定义Observable。是将Observable定义为DataService属性并在构造函数中初始化它，还是直接从服务getter<e
浏览 2提问于2016-06-16得票数 8
我有一个简单的HTTP调用： const url = `${this.apiBaseUrl}/orgs.delay(new Date(Date.now() + Math.random() * 500))但是，当HTTP调用返回多个值的数组时注意:我导入了增强import 'rxjs
浏览 3提问于2017-12-01得票数 0
回答已采纳
2回答
我有一个端点，它生成产品的json列表。我在产品代码中定义了自定义类类型。我试图从端点获取数据，并将产品的json数组转换为products的数组。this.fetchProducts().subscribe(data => { })
fetchProducts(): ObservableConverting to json 2&qu
浏览 3提问于2017-07-21得票数 12
回答已采纳
我是RxJava的新手。我目前正在修改一个现有的同步流，并使用现有方法的返回观察值使其成为异步的。
在其中一个流程中，我进行了一个远程调用，以从DB接收一个项目。由于对数据库的调用是异步的，因此会返回一个可观察对象。但是，数据库中可能不存在该项，在这种情况下，该值将为NULL。如果该值为NULL，我需要对各种其他远程服务进行额外的异步调用，并最终
浏览 6提问于2016-07-27得票数 0
回答已采纳
1回答
我想对一个可观察到的值应用一个异步转换函数。Injectable constructor(private http: HttpClient){}
return this.http.get(url);}
在上面的代码中，我想对由myFunc发出的值应用一个转换函数myFunc，它返回一个允诺。通常，我会使用Rx
浏览 3提问于2017-12-07得票数 2
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
