观察对象动态数组与switchMap函数串联运行一次，即使某些函数失败，也会全部完成
。
观察对象动态数组是指一个包含多个观察对象的数组，每个观察对象都可以发出值并被订阅。switchMap函数是一种操作符，用于将一个观察对象转换为另一个观察对象，并且只返回最新的观察对象的值。
当观察对象动态数组与switchMap函数串联运行时，它们的执行顺序如下：
- 首先，观察对象动态数组中的每个观察对象会按照数组的顺序依次执行。
- 对于每个观察对象，switchMap函数会将其转换为另一个观察对象，并且只返回最新的观察对象的值。
- 如果某个观察对象的转换过程中发生错误，switchMap函数会将错误传递给订阅者，并且不会影响其他观察对象的执行。
- 最终，所有观察对象都会完成执行，即使其中某些观察对象的转换过程中发生了错误。
观察对象动态数组与switchMap函数的组合可以用于处理一系列异步操作，例如网络请求或数据库查询。通过串联运行这些操作，即使其中某些操作失败，也可以确保其他操作都能够完成执行。这对于保证数据的完整性和一致性非常重要。
腾讯云提供了一系列与云计算相关的产品，以下是一些推荐的产品和产品介绍链接地址：
- 云服务器（ECS）：提供弹性计算能力，支持多种操作系统和应用场景。详情请参考：https://cloud.tencent.com/product/cvm
- 云数据库 MySQL 版（CDB）：提供稳定可靠的云端数据库服务，支持高可用、备份恢复等功能。详情请参考：https://cloud.tencent.com/product/cdb_mysql
- 云原生容器服务（TKE）：提供高度可扩展的容器化应用管理平台，支持快速部署和运行容器化应用。详情请参考：https://cloud.tencent.com/product/tke
- 人工智能平台（AI Lab）：提供丰富的人工智能算法和模型，支持图像识别、语音识别、自然语言处理等应用。详情请参考：https://cloud.tencent.com/product/ai
- 物联网套件（IoT Hub）：提供全面的物联网解决方案，支持设备连接、数据采集和远程控制等功能。详情请参考：https://cloud.tencent.com/product/iothub
请注意，以上推荐的产品仅代表腾讯云的一部分云计算产品，更多产品和服务请参考腾讯云官方网站。
相关·内容
我有一个数组，值的类型是无关的。我想做的是每隔x秒发出一个值，用这个值调用一个函数，如果该函数由于某种原因失败，那么在y秒之后重试它(可以是一个简单的常量，这里不需要任何增量)。
到目前为止我拥有的
Rx.Observable
.interval(500)
.take(arr.length)
.map(idx => arr[idx])
.flatMap(dt => randomFunc(dt))
.catch(e => conosle.log(e))
.retry(5)
.subscribe();
function r
浏览 2提问于2017-02-19得票数 2
回答已采纳
1回答
我正在尝试将promises从indexDB库'idb‘转换为一个可观察值。将值放入数据库是可行的，但在初始化我的服务时，我希望它检查indexDB中是否有要获取的值。
要做到这一点，我需要在调用我拥有的getTable函数之前确保indexDB初始化已经完成。到目前为止，初始化起作用了，但之后读取值却不起作用。
private indexDB: IDBPDatabase<DatabaseSchemaV1>;
indexDB$ = new Subject<IDBPDatabase<DatabaseSchemaV1>>();
private init
浏览 11提问于2021-02-23得票数 0
4回答
是否有一种方法可以在createEffect函数中分派多个操作？
loadMovies$ = createEffect(() =>
this.actions$.pipe(
ofType('[Movies Page] Load Movies'),
mergeMap(() =>
this.moviesService.getAll().pipe(
map(movies => /* return an array of actions */ [
浏览 6提问于2021-10-11得票数 0
我对角4和Observables以及所有与它相关的东西都很陌生。我试图一个接一个地执行两个http请求(只有当第一个成功时，才会执行请求)。
我用的是这个代码：
public getCompany(id: string): any {
let company = null;
this.authService.isValidUser().subscribe(response => {
const token = this.tokenStorageService.getTokenFromStorage();
const requestUrl = en
浏览 4提问于2017-08-28得票数 6
回答已采纳
1回答
如果我向服务器发出了新的http请求，但它不像我所期望的那样工作，我想取消以前的http请求。
如果某个值在函数中被更改，我想取消请求，我的意思是，如果值更改，旧请求应该取消，新的请求应该为此创建，我已经这样做了
创造了一个可以被观察到的事物
public stringVar = new Subject<string>();
2)创建一个可以观察到的对象，并发送一个更新流(您将订阅这个以获得更新流)
public stringVar$ = this.stringVar.asObservable()
3)在一个特定的函数中，我得到了作为参数的值，所以我执行以下步骤
testFun
浏览 0提问于2019-07-09得票数 6
回答已采纳
1回答
我已经创建了一个retry函数，它可以在请求失败时调用，以便它可以重试它。这样做的想法是，当用户的令牌过期时，请求将失败，因此，如果令牌过期，它应该刷新令牌并使用新令牌重试，但它仍然使用旧的令牌重试。不知道该怎么做才能让重试考虑到新的价值。
这是重试功能：
http_retry(maxRetry: number = 5, delayMs: number = 2000) {
return (src: Observable<any>) => src.pipe(
retryWhen(_ => {
retu
浏览 1提问于2019-04-28得票数 4
回答已采纳
1回答
我有一个组件A，从那里我使用behaviourSubject向组件B广播数据，在组件B中，每次单击组件中的一个按钮，就应该触发一个http请求。
在组件B中，我订阅了可以从组件A中观察到的溴化铸造。
构成部分A：
import { Component, OnInit } from '@angular/core';
import { MessagingService } from '../messaging.service';
@Component({
selector: 'app-comp-a',
templateUrl
浏览 0提问于2018-10-05得票数 0
我在角5中有两个不同的httpClient请求实现。
在一种方法中，我在方法中有一个http请求，在该方法中，我在.subscribe()方法中再次对另一个表执行第二个(嵌套) http请求，以从两个不同的表中检索数据：
this.http.get<any>(someUrl, {observe: 'response'}
).subscribe(fp_resp => {
if (fp_resp.status === 200) {
this.predictionData = this.chart_PrognoseService.formatData
浏览 0提问于2018-07-31得票数 0
回答已采纳
我有以下代码
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
回答已采纳
我需要动态构建一个可观察对象列表，然后一个接一个地执行这些可观察对象，一旦它们都运行完，我需要调用另一个函数(即检查是否仍然存在任何"offlineJobs“，然后返回true或false)，即使一些或所有可观察对象都失败了，该函数也应该运行。 目前，我有以下内容，但这似乎不起作用： updateOfflineJobs(): Observable<boolean> {
return this.jobsLocal.getOfflineJobIds().pipe(
switchMap(jobIds => {
// Create array of ob
浏览 5提问于2020-08-04得票数 1
回答已采纳
1回答
我们有一个无法完成的rxjs订阅。我想知道这是rxjs库中的错误，还是我们做错了什么。
我们的代码如下所示：
private loadGroups(): void {
if (this.groupOptionsSubscription?.closed === false){
this.groupOptionsSubscription.unsubscribe();
}
this.groupOptionsSubscription =
this.lookupService
.getGroupLookups(null, this.fi
浏览 1提问于2021-11-15得票数 1
4回答
如果我需要提供更多的代码或解释，请告诉我。
我正在尝试执行验证，如果验证不成功，请确认(是/否)，然后在for循环中保存所有选定行的方法。
需求:在循环遍历所有选定的行后，我已经显示了一条成功/失败消息。这意味着：
如果选择了5行(2行有效，3行无效)，则从myService.validate获取
它将询问您是否还想继续处理3条无效记录- myConfirmService.confirm
它应该保存这两个有效的记录。
如果用户在“确认”窗口中选择“是”(让我们说2条记录)，那么它也应该保存这2条信息。
最后，它将显示成功/失败消息- alertService.success。
我想要的：
来满
浏览 5提问于2021-05-20得票数 3
回答已采纳
我被Rxjs的操作员困住了。
这是角的护卫canActivate的一部分
const ifNoPatientCondition$ = this.dataService.getList().map(pl => {
console.log('im here'); // <<< this message not showing
const found = findOnlyAvailablePatients(pl);
if (found[0] === 1) {
this.stateService.patient.setCurrent(foun
浏览 0提问于2018-05-22得票数 3
回答已采纳
2回答
我试图在我的应用程序中有一个无限滚动部分。为了实现这一点，我使用来处理滚动事件等等。当滚动到div底部时，我调用一个函数来获取更多数据。到目前一切尚好。
为了提高此函数的效率，我尝试在调用之前等待几秒钟，并确保数据被正确处理。要做到这一点，我一直在查看上显示的示例。
我有一个与本文中显示的类似的设置，我的问题是，当我调用switchMap()时，我得到了以下错误
Type 'void' is not assignable to type 'ObservableInput<{}>'
这是我的代码示例：
private scrollEndActive:
浏览 5提问于2017-05-18得票数 5
在这种情况下，我们一次只希望发出一个HTTP请求，并且只希望在挂起的调用成功或失败时允许重试或再次调用。我们一直在做经典的布尔值包装，但我们想知道是否有一个运算符。我的直觉是没有。
浏览 0提问于2017-06-21得票数 0
我有多个角度项目，每个项目都有一个服务来调用相同的API。我一直在为请求添加一个标题，以确定请求是从哪个应用程序发送的。因此，我一直试图创建一个具有基服务类的库，以设置标头值
@Injectable({ providedIn: "root" })
export class AppbaseService {
scope: string;
constructor(@Inject(forwardRef(()=>'scope')) scope:string) {
this.scope =
浏览 1提问于2021-05-20得票数 1
回答已采纳
1回答
父组件将id号传递给我的子组件，然后我想使用这个id来获取具有几个属性的值。我写了一个服务，通过返回可观察的方法来找到确定的内容。然后，我想在我的html中显示这个可观察的id，但是它失败了，它说TS2339: Property 'id‘不存在于’可观察的‘.类型上。
我的html代码
<h2>{{dog$.id}}</h2>
组件代码
dog$!: Observable<Dog>;
ngOnInit() {
this.dog$ = this.route.paramMap.pipe(
switchMap((param
浏览 4提问于2021-12-13得票数 0
我如何构造一个以预定间隔发射的可观测对象，但也可以使其在第二个可观测对象发射时发射，此时间隔将被“重置”，以从第二个ping的点开始以原始间隔再次发射？
例如，假设间隔为10分钟。可观测点将在10，20，30等处发射，但假设第二个可观测点在时间15处发射，那么总体可观测点应在10，15，25，35等处ping。
浏览 4提问于2016-09-17得票数 13
1回答
我使用的是QueryList @ViewChildren(SortableTableColDirective)
sortableHeaders!: QueryList<SortableTableColDirective>; 该指令有一个主题，当特定列的排序顺序改变时将发出该主题。 ...
private _sort$ = new Subject<SortEvent>();
get sort$(): Observable<SortEvent> {
return this._sort$.asObservable();
}
浏览 20提问于2021-05-04得票数 0
回答已采纳
我有一个动态数组结构。具体来说，这是谷歌地图的。这个结构有常规的put、get、remove方法，以及一个addListener来侦听任何更改。库方法(Polygon#getPaths)返回MVCArray of MVCArray of LatLngs，因为多边形可以有任意数量的路径，而每条路径可以有任意数量的顶点。
我的目标是转换生成一个可观察到的PolygonPathEvent，当父MVCArray、任何子MVCArray将被更改时，它都会触发。
创造可观测值
第一要务是将addListener转换为可观测的。
private createMVCEventObservable<T&g
浏览 0提问于2019-03-16得票数 2
回答已采纳
在这里播放代码，=>
嗨，我正在尝试模拟一个失败的API调用，它将在订阅(){ Error：}部分发出错误值。
import { from, of, pipe, forkJoin, interval, AsyncSubject, BehaviorSubject,defer, Subject, timer, observable, throwError } from 'rxjs';
import { concatMap, map, mergeMap, zipWith, delay, tap, concatAll, concat, concatWith, switchMap
浏览 8提问于2022-02-18得票数 3
回答已采纳
1回答
最近，我将一个函数转换为从磁盘(而不是内存)动态检索数据，在此过程中，从同步返回变量到返回可观察到的变量。
作为此转换的一部分，每个依赖函数都必须通过可观测值转换为异步，其中一个函数执行嵌套的条件调用，该调用获取类别的最后一个场景，或者如果没有先前的场景，则生成一个默认场景：
public generateScenario(category: string, value: number = 1) : Observable<Scenario>
{
return this.getHistory(category).map(scenario => {
if(
浏览 0提问于2017-12-11得票数 2
回答已采纳
2回答
我目前正在跟踪Jogesh Muppala在Coursera上的角航向，问题是下面的代码行。
this.route.params.pipe(switchMap((params: Params) => this.dishService.getDish(+params['id'])))
其余代码如下所示。到目前为止，我的理解是this.route.params是可观测的，而this.dishService.getDish(+paramsid)也会返回一个可观测的。我的问题是理解(params: Params)是如何到达那里的。它用作箭头函数中的参数，在语句末尾附近由ge
浏览 0提问于2018-08-13得票数 0
回答已采纳
1回答
我试图从后端API中获取数据，但我不知道如何在另一个对象中获取一个对象。
下面是我后端的回应：
{
"id": 4,
"website_id": 1,
"user_id": 5,
"username": "Swarton3"
},
{
"id": 5,
"website_id": 1,
"user_id": 5,
"username": "Test123"
}
在websi
浏览 1提问于2022-05-11得票数 -1
回答已采纳
1回答
我试图用图片将一个项目添加到我的防火墙中，因为base64图片大于2Mb，所以我使用防火墙来存储图像，并获得设置相应字段的url。
要做到这一点，我将我的项目用一个空字段发送到firebase，然后，我将图片发送到firebase存储。在此之前，一切都还好，但是当我试图获取下载url并将其设置为我的项目时，它就不能工作了。
这是我的代码：
这里是我的页面，在这里我要向消防局添加一个新的项目。
export class AddFoodPage implements OnInit {
...
addFood() {
this.setFood();
this.foodServic
浏览 2提问于2021-09-09得票数 0
回答已采纳
我有两个可以观察到的
baseObs$ = serviceCall(); // this return Observable<Foo>
secondObs$ = serviceCall(args); // this return Observable<Bar>
本例中的args是在其他地方定义的公共变量。不过，如果这样做更容易的话，那就不需要了。
baseObs我可以随时调用，但只有在成功调用和处理baseObs之后才能调用secondObs (不知道正确的单词，下面是示例)：
我现在有了
baseObs$.subscribe(x => {
const arg
浏览 2提问于2021-04-19得票数 0
回答已采纳
1回答
我有一个可观察的，返回为可观察的数据，这是绑定与异步使用HTML。
我已经打电话给服务部门了。
this.ProductOptions = this.ProductService.fetchProduct();
在HTML中，我们将绑定作为
Productoptions | async.
它很好用。
在另一个函数调用中，我已经根据产品名称进行了筛选，但它不起作用。
getCategory() {
const productListOptions = this.productOptions.pipe(
switchMap((itemList: BindingModel[]) =>
浏览 0提问于2018-09-18得票数 0
我已经搜索了一个类似的问题，但找不到一个匹配的，所以如果这是重复的，很抱歉。 我有几个链式的观察点。 可观察性A通过switchmap调用可观察性B。 现在，可观察到的B实际上是一个行为主体，但我认为这与问题无关。 现在，可观察的B永远不会完成。它不断地传递true或false。 当可观测B接收到TRUE值时，它通过切换映射调用可观测C。可观察的C通过switchmap执行任务并调用其他可观察的对象。以此类推。 我需要做的是，当observable B接收到false时，它什么也不做(目前是这样设置的)。当observable B接收到true时，它调用observable C(当前有效)。
浏览 8提问于2018-12-26得票数 0
回答已采纳
首先，我对可观察到的东西不是很熟悉，所以我必须请你们在我的脑海中保持清晰。我正在开发一个web-app，它有一个Angular客户端和一个Rails服务器。对于从客户端到服务器的每个请求，我想创建一个任务并将其添加到任务列表中。这是我的ServerTask类： export class ServerTask {
private _state$ = new BehaviorSubject<ServerTaskState>({type:"pending"});
readonly state$ = this._state$.asObservable();
浏览 25提问于2020-04-08得票数 0
下面代码的过程是从api获取电子邮件id，并解析该电子邮件id的细节。我需要直接返回详细信息作为响应，而不是需要订阅，因为我刚刚将this.route.snapshot.data.value分配给一个组件，它立即获取数据。有没有办法做到这一点？请多多关照。我以前没有在resolve中写过嵌套的，所以请指导。我只是试了一下，如下所示，但它不能满足需要。 resolve() {
let info = environment.DETAIL_URL;
return this.appService.getInfo(info).pipe(map((res) =&
浏览 15提问于2020-07-04得票数 1
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
回答已采纳
1回答
我有两个可以观察到的
const refreshClick$ = Observable.fromEvent(this.btn, 'click').startWith('click')
const interval$ = Observable.interval(5000, 5000)
this.subscription = interval$
.merge(refreshClick$)
.flatMap(() => this.grabSomeData())
.subscribe(newState => this.setState({new
浏览 3提问于2017-09-26得票数 0
回答已采纳
对于我的应用程序的搜索功能，我有一个热门的可观察的链，做以下工作。
接受EditText ( TextChangedEvent)中的用户输入字符串(在mainThread上)
300 on(在computation线程上)
显示加载旋转器(mainThread)
使用该字符串查询SQL (此查询可以从100 on到2000 on不等)(在Schedulers.io()上)
向用户显示结果(mainThread)
因为步骤3的长度是可变的，所以会出现一个竞赛条件，其中显示的搜索结果比最近的结果要少(有时)。假设用户想输入chicken，但是由于输入速度怪异，单词的第一
浏览 3提问于2015-08-04得票数 3
回答已采纳
1回答
我希望使用动态数据创建嵌套菜单。第一层工作正常。但我在显示子菜单时遇到了问题，当我单击父菜单时，子菜单替换了主菜单。这是我的代码：
ngOnInit(): void {
this.appService.getCatalogueCategories(1, { pos: '6196319a431f76d2acd3c27d' }).subscribe((res: any) => {
this.catalogueCategoriesL1 = res;
this.catalogueCategories = res;
});
}
ge
浏览 3提问于2022-06-29得票数 0
1回答
我正在尝试订阅一个可观察到的“加载”，它返回一个布尔值。如果加载为true，则目标是使流中的项延迟，但如果加载为false，则不延迟。也应该可以忽略一个过时的项目，让我们假设如下情况：
流中有两项：
项A的值为true，并立即传递
项B值为false，并在200 is之后传递。
A项的值为true，因为它将延迟500 by，所以B项不会延迟。在这种情况下，B项将在A项之前到达。我正在寻找一个解决方案，完全忽略上述情况下的A项。
在这里，你可以看到我目前的解决方案：
this.loading$
.pipe(
distinctUntilCha
浏览 0提问于2018-04-14得票数 1
回答已采纳
我试图避免下列情况：
switchMap(([action, state]) =>
from(TodosDB.getAll()).pipe(
map(
(todos) => onQueryTodoDone({ items: todos }),
catchError((err) => of(onQueryTodoFail({ error: err })))
)
)
),
就像我们在ngrx中使用combineLatestFrom一样。到目前为止，我试着做下面的工作。但这一承诺似乎行不通。
withLatestFrom(
fro
浏览 10提问于2022-12-02得票数 1
1回答
我不太擅长JS和RxJS，所以如果我的问题很愚蠢，对不起。
我有这个代码，不是我写的：
prepare(): Observable<any> {
const i = of({}).pipe(
// Check if file type is image
filter(() => isImage(this.file)),
switchMap(() => this.generateThumb()),
switchMap(() => this.resizeImage()),
take(1)
浏览 1提问于2019-02-07得票数 2
我很难理解RxJS和如何处理错误。我使用的是角(4+)，随着它们切换到RxJS来处理简单的HTTP请求，我发现自己不得不为一些看似微不足道的事情而努力奋斗。
以下是我精心设计的代码：
import { Component, OnInit } from '@angular/core';
import 'rxjs/add/observable/from';
import 'rxjs/add/observable/of';
import 'rxjs/add/observable/empty';
import 'rxjs/add
浏览 1提问于2018-01-17得票数 2
回答已采纳
1回答
我正在开发一个angular 7应用程序，我知道嵌套的订阅函数是一种反模式，但正确地使用了转换操作符(如mergeMap，switchMap ...)在管道函数中，我总是可以避免它。我正面临着这样一种情况:我不能理解内心的可观察性是如何工作的。我有一个过滤器的形式，它是完全初始化事件后，由一个可观察的信号，在这个事件之后，我必须通过formGroup上的.valueChanges侦听表单更改，格式化过滤器，并最终过滤结果。
this.filters.categoriesReady.asObservable()
.pipe(
tap((categories) =>
浏览 12提问于2019-08-03得票数 0
我在一个角度应用程序中使用了以下代码。我使用的RxJS map调用类似于数组map的使用方式。在阅读了关于RxJS switchmap运算符的文章之后，我不确定应该使用map还是switchmap。我是否应该使用switchmap，以便关闭从http调用返回的可观察到的内存，从而没有内存泄漏？
getPeopleForTypeahead(term: string): Observable<IPersonForTypeahead[]> {
var peopleUrl = `https://localhost:5001/api/peoplesearch?name=${term
浏览 12提问于2022-05-20得票数 1
回答已采纳
我在尝试运行git bash时遇到了这个问题。.switchMap未执行，并显示错误为“error TS2339:属性'switchMap‘在类型'Observable’上不存在”“
我使用的代码是：
import { User } from './../classes/user';
import { Injectable } from '@angular/core';
import { Router } from '@angular/router';
import { Observable, of } from 'rxj
浏览 0提问于2019-03-17得票数 2
1回答
假设用户输入触发http请求A，如果结果为A，应用程序必须发出另一个请求B并显示最终结果。
如果接收到新用户输入，则应取消所有http请求。
我举的例子是链接switchMaps。新的单击将中止并重新启动第一个switchMap请求。第一个switchMap的新输出将取消并重新启动第二个。但是，单击将不会重新启动第二个switchMap。
关于如何重新考虑这个问题，我会很感激的。取消请求是目标，过滤/忽略结果是欺骗:)。
function obFc(name) {
return {
next: function (x) { console.log(name+ ' - &#
浏览 1提问于2018-06-29得票数 2
回答已采纳
1回答
如何订阅可观察到的副作用？
、、、、
我有一个方法，它调用另一个服务来播放播放器中的流url。playStream$()返回一些流数据，这些数据也应该从play$()方法返回。作为播放流的一个副作用，我想发送一个由间隔触发的心跳。
play$(streamId: number, position?: number): Observable<Stream> {
return this.playerService.playStream$(streamId, position)
.pipe(
tap(() => this.heartbeat$(streamId).subscribe())
浏览 5提问于2022-01-26得票数 1
我用redux
export const createPaymentMethod =
(getBraintreeToken: (Object) => Promise<*>, cardholderName: string) => ({
type: CREATE_PAYMENT_METHOD,
getBraintreeToken: () => getBraintreeToken({ cardholderName }),
});
const mapBraintreeError = err => Observable.of({
type
浏览 2提问于2018-01-11得票数 1
回答已采纳
2回答
对rxjs中开关图的理解
、、、、
我对rxjs很陌生。我正在尝试理解开关图的功能。为了理解，我编写了以下代码。
const fun1 = () => {
return new Promise((resolve, reject) => resolve("Fun1"));
};
const fun2 = () => {
return new Promise((resolve, reject) => resolve("Fun2"));
};
const fun3 = () => {
return new Promise((resol
浏览 5提问于2021-04-15得票数 0
回答已采纳
1回答
我的问题类似于这个 (没有答案)。
我想继续解析一些页面。在主页面中，我可以获得要解析的页面链接列表。此链接列表随着时间的推移而变化。然后，我跟踪链接，并继续解析页面，直到它们的链接从主页中消失，并开始解析新页面，因为它们出现在主页上。
我现在的设置如下。我有一个给出url的类，它可以返回连续发射项的Observable (解析主页中的单个链接)。这个很好用。但是，我希望有一个“主”类，它将能够返回一个可观察到的相同项目，但从多个页面中获取。我遇到的问题是页面列表正在改变(底层Observable的列表也是如此，我不能只使用Observable.merge )。
TL；博士:我想合并多个Obs
浏览 0提问于2018-09-28得票数 0
回答已采纳
2回答
我有一个字符串数组，它们也是我的Firebase实时数据库中端点的键。我想遍历这个数组，并获取每个键的Firebase对象。
我没有得到以下代码的响应
有没有一种动态订阅Firebase可观察性的方法？
sortedArray:any = ["x","y","z"]
方法：
getItems() {
this.sortedArray.forEach(el => {
this.ngDB.object(`items/${el}`).valueChanges()
.toPromise()
浏览 2提问于2018-03-20得票数 0
在我的组件的ngOnInit中，我按照中的建议使用paramMap来重用组件，但要根据路由中提供的用户id进行切换：
this.route.paramMap
.switchMap((params: ParamMap) => {
this.errors = false;
this.busy = true;
return this.userService.getUser(params.get('id'));
})
.subscribe((user)
浏览 0提问于2017-08-31得票数 0
目前，我正在与RxJ打交道，并试图定义返回可观察性的模块。(每个模块都是一个黑匣子，只公开其可观察到的内容)。我的主要问题是由于我使用的第三方库: UWA :我所有的dom元素都是从UWA对象生成的，并触发UWA“事件”。顺便说一句，我想把那些定制的事件映射到可观察的地方。下面是事件数据结构的一部分：
tabBar = *somecode*...{
....
onEndEditTab: function (callback) {
return this.modelEvent.subscribe({
event: endEditTabEvent
}, callba
浏览 5提问于2017-08-10得票数 1
回答已采纳
2回答
我正在尝试获取连接到我的应用程序的打印机的状态。下面是我在其中一个页面中的函数： checkPrinterStatus() { //I want to this this function into an observable
this.afdb.object('food/settings/printer').snapshotChanges().subscribe((res: any) => {
const printerSettings = res.payload.val();
if(printerSettings.isConnecte
浏览 24提问于2020-08-21得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
