RxJS连结两个观测值
RxJS是一个流式编程库，用于处理异步和事件驱动的程序。它提供了一套丰富的操作符，允许开发者通过组合和转换观测序列来简化异步编程。
RxJS的核心概念是Observable（可观察对象），它代表了一个持续产生值的数据源。开发者可以使用各种操作符来处理和转换Observable，包括过滤、映射、合并、转换等等。通过将多个操作符链式组合，可以实现复杂的异步逻辑。
在RxJS中，连结两个观测值可以通过使用操作符进行组合。常用的操作符包括concat、merge、combineLatest、zip等。
- concat操作符用于连接多个Observable，当第一个Observable完成时，才会订阅并发出第二个Observable的值。
示例代码：
observable1.pipe(concat(observable2))应用场景：当需要按照特定顺序执行多个异步操作时，可以使用concat操作符进行顺序执行。 - merge操作符用于合并多个Observable，它会同时订阅并发出所有Observable的值，不关心它们的顺序。
示例代码：
merge(observable1, observable2)应用场景：当需要同时处理多个异步操作的结果时，可以使用merge操作符进行合并处理。 - combineLatest操作符用于将多个Observable的最新值进行组合，并返回一个新的Observable。
示例代码：
combineLatest(observable1, observable2)应用场景：当需要根据多个异步操作的最新值进行处理时，可以使用combineLatest操作符。 - zip操作符用于将多个Observable的值一一对应地进行组合，并返回一个新的Observable。只有当所有Observable都发出值时，才会发出组合后的值。
示例代码：
zip(observable1, observable2)应用场景：当需要将多个异步操作的结果进行一一对应的组合时，可以使用zip操作符。
以上是RxJS中用于连接两个观测值的常用操作符，通过灵活使用这些操作符，可以实现各种不同的异步编程逻辑。
腾讯云提供了Serverless云函数（SCF）作为基于事件驱动的计算服务，可以与RxJS相结合，实现更高效的异步编程。您可以通过以下链接了解腾讯云函数SCF的相关产品信息： 腾讯云函数SCF产品介绍
请注意，以上回答中并未提及亚马逊AWS、Azure、阿里云、华为云、天翼云、GoDaddy、Namecheap、Google等流行的云计算品牌商。
相关·内容
当数据输入时，我想显示分析的部分结果。重新计算每一个新值(就像使用“扫描”)是非常低效的。但是，在这种情况下，我可以对数据块进行分析并组合这些结果。因此，我一直使用“窗口”来分解数据，然后使用“扫描”来组合每个窗口计算的结果。其结果本身就是一个可观测的，因此将其作为嵌套的可观测的，这将是非常自然的。而且，当使用可观察到的数据时，这个过程中的下一个步骤非常有效。
然而，我无法像我所期望的那样让它发挥作用。(我确实用了一个尴尬的步骤，将内部可观测数据转换为数组，然后再返回到可观测数据。)关于“窗口”和/或“扫描”，似乎有些东西我不明白。
以下是两个不同的示例，说明了如何生成嵌套的可观测性。我本以为
浏览 1提问于2020-06-08得票数 2
回答已采纳
我正在将exhaustMap应用于一个可观测对象，由此可以创建两个投影的可观测对象。两个投影的观测点中的第二个在第一个投影的观测点完成之前不应该开始发射。因此，我期望输出可观测值会从两个投影的可观测值中发出项。但出于某种原因，第二个观察点被忽略了。请注意，第二个投影的可观测对象直到7秒后才开始发射--这远远超过了第一个投影的可观测对象发射其最后一项的时间点。下面是我的代码示例： import { from } from 'rxjs';
import { interval } from 'rxjs';
import { take } from 'rxj
浏览 14提问于2021-09-14得票数 1
回答已采纳
我已经开始使用RxJS5，现在看到不再有shareReplay方法了。
我很可能经常在RxJS4中滥用RxJS4，但现在我很难得到我想要的行为，即：
创造一个可观察的
订阅可观测值，可观测值产生值。
第二次订阅可观测值，我得到相同的第一个值。
可观察性生成第二个值，两个订阅都获得第二个值。
如何用RxJS5实现这一点？
总的来说，我认为我对RxJS运算符的理解相当好，但是对我来说，整个冷、热、发布、连接都是相当不清楚的。是否有一个很好的参考资料来说明如何找到我所拥有的可观察的类型，这样我就可以以逻辑的方式找出为什么订阅没有得到值，或者为什么一个可观察到的值被多次执行？
浏览 3提问于2016-01-04得票数 12
回答已采纳
3回答
RxJS过滤器()算子
、、、、
我试图找到使用filter()操作符的最干净的解决方案，以便过滤我的可观测值。
在这里，我复制服务调用以分别获得一个femaleList
export class MyComp implements OnInit {
maleList: IContact[] = [];
femaleList: IContact[] = [];
constructor(private _contactService: ContactService) { }
ngOnInit() : void {
this._contactService.getCont
浏览 0提问于2016-12-13得票数 0
回答已采纳
示例1:
var obsNumber = /* observable that produce numbers */;
var obsText1 = /* observable that produce text */;
var obsText2 = /* observable that produce text */;
var obsContext = /* IF obsNumber < 5 THEN obsText1 ELSE obsText2 */;
obsContext是一个可观察的，它将从obsText1或obsText2返回数据，这取决于obsNumber的值。
示例2:
v
浏览 2提问于2013-06-28得票数 3
回答已采纳
我需要澄清操作管道在RxJS中的效率。
我目前对RxJS中的操作符管道的了解是，管道中的每个操作符接收一个可观测的，并创建一个新的(可能修改的)可观测的，作为输入返回给下一个操作符。这种行为将类似于JavaScript过滤器，映射，减少行为。因此，保留原始的可观测(流)或数组未接触/纯。
这个假设得到了RxJS文档：的支持。
Pipeable运算符是一个函数，它将一个可观测的输入作为其输入，并返回另一个可观测的函数。这是一个纯粹的操作:以前的可观察到的保持不变。
考虑到长的操作员管道，创建中间可观测数据对我来说似乎是很昂贵的。
此外，我正在阅读由Sergi编写的“用RxJS 5进行反应
浏览 0提问于2020-02-25得票数 3
RxJS 是一个实例方法。要调用该方法，必须更新/创建可观察到的实例。
方法是一种静态方法。不需要实例。
为什么RxJS withLatestFrom不是静态方法，而是实例方法？
浏览 1提问于2017-04-17得票数 3
回答已采纳
有理解角度可观测性的困难。我正在创建一个可观测的对象，它发出一个随机数一次。我有两个订阅者，我得到了两个不同的号码。如果我有3个订阅者，我会得到3个不同的号码。我知道用observable我们只能得到一个数字。
const observable = Rx.Observable.create((observer) => {
observer.next(Math.random());
});
// subscription 1
observable.subscribe((data) => {
console.log('Observer Subscriber A
浏览 2提问于2019-03-06得票数 2
我目前正在做一个从我的前任那里继承下来的项目，在那里我们从外部源获取数据，并希望将其可视化。我继承的代码提供了两个可观察的值，每一个都有一个值数组(两者长度相等)。我想要压缩这些可观察的数据，所以我得到了一个可观察的，与以前一样的(index:value)，我得到了(value 1:value 2)。
我尝试了rxjs中的zip函数，但这只将两个可观测值不变地放入另一个可观测值中，我试图将可观测数据的内容映射到新的可观测值上，但显然不能映射可观测数据。这可能很明显，但我对整个rxjs非常陌生。
浏览 1提问于2019-07-07得票数 0
回答已采纳
如图中所示，我有两个订阅项：
其中一个是搜索输入，另一个是选择过滤器。我想改变结果，当其中一个或两个变化。我使用Rxjs combineLatest，所以当它们或搜索输入都发生变化时，一切都正常，但是在第一次更改合作伙伴类型时，响应不会改变。
ngOnInit() {
super.ngOnInit();
this.getAllPartners();
combineLatest([this.searchPartnerFc.valueChanges, this.filterFc.valueChanges])
.pipe(
switchMap(([search, filter])
浏览 6提问于2022-08-20得票数 1
回答已采纳
在角2+中，我设置了一个警卫。
下面的代码模拟它的行为，内部of(true).pipe(delay(5000))模拟一个API调用，该调用应该告诉用户是否经过身份验证并能够访问受保护的组件。
import { BehaviorSubject, of, switchMap, delay, tap } from 'rxjs';
import { CanActivate } from '@angular/router';
class MyGuard implements CanActivate {
readonly auth$ = new BehaviorSub
浏览 2提问于2022-08-27得票数 0
回答已采纳
1回答
我有一个可以观察到的RxJS，它在0到1000 an之间的随机时间后发出值。
我如何断言在每个可观测到的发射之间至少有一个200毫秒的差距？不应删除/跳过任何值，并且仍应按其传入的顺序发出值。
浏览 1提问于2022-07-08得票数 0
回答已采纳
我对角和RxJS相当陌生，我很难了解RxJS操作符的某些方面。我这里有一些代码(在组件中)：
this.salesService.getOrders().subscribe(orders => {
this.orders = orders;
this.orders.forEach((order, index) => {
this.salesService.getOrderCustomers(order.id).subscribe(customers => {
this.orders[index]['customerName'] =
浏览 11提问于2022-10-13得票数 1
回答已采纳
2回答
我正在尝试轮询一个RESTful端点来刷新我的实时聊天消息。我知道在线聊天的最好方法是Websockets，我只是想了解RxJS如何与角锥2一起工作。
我想每秒钟检查一次新消息。我有以下代码：
return Rx.Observable
.interval(1000)
.flatMapLatest(() => this.http.get(`${AppSettings.API_ENDPOINT}/messages`))
.map(response => response.json())
.map((messages: Object[]) => {
浏览 7提问于2016-01-26得票数 11
回答已采纳
我有两个相同类型的可观测值，我想合并成一个可观察的，并删除重复的。
到现在为止，我基本上尝试了所有的rxjs操作符，但是没有一个能满足我的需要。请参阅附图:许多rxjs操作符更改了结果可观察到的类型。
const a: Observable<Foo[]> = ...
const b: Observable<Foo[]> = ...
这是我检索一些数据的两个调用。
现在最接近的两个操作是：
combineLatest(a, b);
这个数组由两个索引组成，a的结果将进入索引0，b的结果将进入索引1，我不能这样使用它。
const c = a.pipe(mergeMa
浏览 4提问于2021-02-11得票数 2
回答已采纳
这是一种复杂情况的简化，在这种情况下，如果值无效，可以过滤数组中的一些可观测值。问题是过滤后的可观测到的不允许其他人完成组合。有什么操作员或方法可以处理这种情况，允许订阅中的有效数据日志？
// RxJS v6+
import { fromEvent, combineLatest, of } from 'rxjs';
import { mapTo, startWith, scan, tap, map, filter } from 'rxjs/operators';
const userData$ = [
of({ name: 'Joseph
浏览 4提问于2020-04-23得票数 1
回答已采纳
我正在使用Rxjs，到目前为止看起来还不错！我有这个问题
我如何才能做到这一点？
// I have observable of observables!
const bad$ = Rx.Observable.of([
Rx.Observable.of(1),
Rx.Observable.of(2),
Rx.Observable.of(3),
Rx.Observable.of(4),
Rx.Observable.of(5)
])
// I want to convert it to something l
浏览 9提问于2018-01-15得票数 1
我对nestJS和RxJS很陌生，并尝试为http请求使用axios。
我注意到在使用API时有两个选项。
使用HttpService.get。它返回可观测值，而together.using HttpService.axiosRef.get应该使用RxJS。它还承诺。
两个选项之间有什么区别？？
(例如)性能，捕捉错误。等等..。
谢谢。
浏览 15提问于2022-07-26得票数 0
回答已采纳
据我所知，javascript将对象作为引用进行传递。因此，如果我调用一个以对象为参数的函数，该函数可以修改它。我写了这段代码：
var rxjs = require("rxjs")
var obj = {}
var stream = rxjs.Observable.of(obj).
do((x)=>{x.index=isNaN(x.index)?x.index=0:x.index++; return x}).
repeat(10).
subscribe(console.log);
它在obj上定义index属性(如果该属性尚不存在)，如果它已经存在，则增加该属性。因
浏览 0提问于2018-01-17得票数 0
回答已采纳
我读了这篇文章的不同之处，但要点如下。
因此，使用tap，我可以改变变量，例如，如果我放置x=3+4，那么它就会改变变量的值，那么我可以说有一个副作用。
但是使用map，我可以更改每个值的循环值，不是吗？你能指出他们有哪些突出的差异吗？
抽头
RxJS tap对源可观测的每个值执行副作用，并返回一个可观察到的与源相同的值，直到没有错误为止。
映射
映射是一个RxJS可调用运算符。映射将给定的函数应用于源可观测到的每个元素，并将结果值作为可观测的发布。
浏览 3提问于2020-04-18得票数 34
回答已采纳
我有两个可观测的，a和b。我想把它们结合成这样：
a: ---x---------x-------x------|
b: ------x-x-x----x-x-x---x-x--|
o: ------x--------x-------x----|
也就是说，我希望在b的第一次发射上，在a发射后直接发射的结果可以被观测到。
我使用的是reactivex/rxjs，但仅仅是概念提示就足够了。提前谢谢你！
浏览 0提问于2016-04-02得票数 1
回答已采纳
2回答
热与冷观测
、、
在RxJS中，热观测是使用外部生产者的可观测性，而冷可观测的是使用本地生产者(参见)。
无论何时打电话，HttpClient.post都会使用冷观测值发送数据和重复。
有什么方法可以从角度上判断某一特定方法是否使用了可观察到的热或冷？
浏览 0提问于2017-09-06得票数 10
回答已采纳
5回答
我想我有一个基本概念，但也有一些模糊之处。
所以一般来说，这就是我使用Observable的方式
observable.subscribe(x => {
})
如果我想过滤数据，我可以使用以下方法：
import { first, last, map, reduce, find, skipWhile } from 'rxjs/operators';
observable.pipe(
map(x => {return x}),
first()
).subscribe(x => {
})
我也可以这样做：
import 'rxj
浏览 1提问于2018-02-07得票数 166
回答已采纳
有两组可观察的(网络请求)。在第一个可观测的解决方案之后，我需要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
回答已采纳
可观测操作符withLatestFrom在RxJS 5中的文档似乎不清楚相互依赖的可观测性(即可观测的钻石模式)的行为。
我的问题非常类似于。以下是简短的说明：
我有三个可观测的A，X和Y。它们被配置成：
X依赖于A。
Y通过withLatestFrom方法依赖于A和X。
在代码中，如下所示：
let a$ = Rx.Observable.interval(...)
let x$ = a$.map(...)
let y$ = a$.withLatestFrom(x$).subscribe((a, x) => {
console.log("a =
浏览 1提问于2017-11-04得票数 1
回答已采纳
我正在尝试理解combineAll操作符是如何工作的。我使用中的以下示例
import { take, map, combineAll } from 'rxjs/operators';
import { interval } from 'rxjs';
const source$ = interval(1000).pipe(take(2));
const example$ = source$.pipe(
map(val =>
interval(1000).pipe(
map(i => `Result (${val}): ${
浏览 1提问于2017-07-19得票数 12
回答已采纳
1回答
当所有可观测值至少发出一个值(combineLatest、forkJoin等)时，我知道如何组合可观测值并获取结果。
但是，当许多可观测值中的一个发出一个值时，我怎么能发出一个值呢？
例如：
const adModelChangedObs$ = this.editAdService.adModelChanged; // Angular subject one
const refreshPreviewClickedObs$ = this.editAdService.refreshPreviewClick // Angular subject two
merge([adModelChangedO
浏览 5提问于2022-02-11得票数 0
1回答
我有一个函数，需要从两个独立的异步函数(返回可观测值)获得2个响应。1. Func1返回可观测性2. Func2返回可观测性--它们不依赖于彼此--它们可以单独运行。功能3应该有一些如何执行Func1和Func2的结果。我正在使用RXJS，并尝试使用管道和flatMap或地图，但仍然没有成功。
浏览 1提问于2019-07-31得票数 2
回答已采纳
Angular2 2.0.0-beta.15，Rxjs 5.0.0-beta.2
我有两个简单的rxjs可观测值，一个是共享的，一个不是(.share()调用的)
我有一个angular2组件，它订阅两个可观测值，并在其模板中显示值，该模板还使用异步管道订阅可观测数据。
我单击一个按钮，用一些垃圾在两个可观察到的位置上设置.next()。
模板更新并显示每个值的最新值。组件中的订阅函数不会为不可见的非共享对象触发。为什么？
柱塞：
@Component({
selector: 'my-app',
template: `
<div>
浏览 1提问于2016-04-14得票数 1
回答已采纳
我在和RxJS做斗争。关于可观察性的几个问题
在调用onCompleted之后，能观察到空数据数组吗？
当我将两个订阅()方法链接在一起时，会出现“订阅类型中不存在订阅”的错误。为什么会这样呢？
someObs.map(...).subscribe(...).subscribe(...)
有没有一种方法可以在不订阅的情况下检查可观测的数据数组计数？
如果“可观测”在发出数据项后清除这些数据项，那么是否有办法在不创建新数据项的情况下将新数据项重新填充到相同的可观测实例中？如果是，怎么做？
浏览 2提问于2016-04-21得票数 1
回答已采纳
1回答
这是我的代码..我需要检查2个可观测数据..it对1个可观测数据有效如何检查另一个可观测数据 import { Injectable } from '@angular/core';
import { ActivatedRouteSnapshot, CanActivate, CanActivateChild, Router, RouterStateSnapshot, UrlTree } from '@angular/router';
import { Observable } from 'rxjs';
import { filter, map,
浏览 13提问于2021-07-11得票数 0
回答已采纳
1回答
我正在跟踪这个，但是当我到达设置env的部分时，我会得到一个错误消息。
$yarn运行启动
import * as Rx from "rxjs/Observable";
console.log(Rx);
如果我把日志放在没有"Rx“的地方，它就会显示得很好。但如果我用日志..。我知道这个错误：
未找到./node/rxjs/观测者.42模块中的错误:错误:无法解析'/Users/manuel/Documents/testeos/JS/rxjs/node_modules/rxjs‘@./node_node/rxjs/观测者.42 6:9-42 @/src
浏览 1提问于2018-08-06得票数 1
回答已采纳
2回答
我有两个可观测值，我想在forkJoin方法中从rxjs合并它们。独立地执行可观测值，但是使用forkJoin它不会到达pipe finalize/subscribe方法。
My.component.ts
....
const req1 = this.userService.getUser(this.loggedInUser.userId);
const req2 = this.boardGames$;
this.subscriptions$ = forkJoin([req1, req2])
.pipe(
finalize(() => {
console.
浏览 4提问于2021-01-03得票数 0
回答已采纳
1回答
下面是一个简单的样本角2组件，它使用rxjs可观测值。
import { Component , OnInit } from '@angular/core';
import { Observable } from 'rxjs/Observable';
import 'rxjs/add/observable/of';
@Component({
selector:'ob',
template: `
<ul>
<li *ngFor="let x of obj
浏览 1提问于2017-03-17得票数 2
回答已采纳
1回答
我有一个问题要过滤一个可观测的数组，在我的例子中是resources$ (一个可观测的，包含所有的‘资源’作为JSON)，我还有另一个可观察的名为usedResources$，我想要实现的只是从这两个变量的unusedResources$ (资源- usedResources = unusedResources)，有什么RxJS方法来实现这一点吗？
浏览 3提问于2017-06-01得票数 1
回答已采纳
我有一个基本组件，试图从Params中获取数据。但是，我注意到，如果我缺少.subscribe()，我的调试代码通常就无法工作。如果在本例中注释掉了.subscribe()，则不会将Got Params??打印到控制台。
this.route.params
.switchMap((params: Params) =>{
console.log("Got params??");
console.log(params);
// params['filename'])
return 'cat';
})
浏览 5提问于2017-02-21得票数 2
回答已采纳
2回答
我有一个web返回一些结构化数据。
{
i: {
f: [...],
a: val,
b: val
},
a: [...],
b: [...],
c: [...]
}
我将此返回到一个有角度的6应用程序--我假设使用的是可观测值和rxjs。我所看到的关于可观测的所有示例都假设一个数组被转换到可观测的数组中。但是，这些数据是结构化的，并且在结构中包含一些子数组。
我不熟悉角度，所以如果可能的话，我在寻找方向。
浏览 0提问于2018-07-18得票数 2
回答已采纳
2回答
我有一个组件，它监听HTML按钮中的单击事件，并从它的父级获取一个可以观察到的事件。当单击按钮时，它需要检查可观察到的状态，检查是否为false，并发出一个事件。我在这里尝试调试反应性代码，但是console.log()没有打印到控制台。
import { Component, ElementRef, EventEmitter, Input, Output, ViewChild } from "@angular/core";
import { combineLatest, fromEvent, Observable, Subject } from "rxjs";
浏览 3提问于2022-07-14得票数 1
我的代码：
import { Employee } from './../employee';
import { Component, OnInit, Input } from '@angular/core';
import { EmployeeService } from '../employee.service';
import { map } from 'rxjs/operators';
import {Observable} from "rxjs";
import { Router, ActivatedRo
浏览 2提问于2020-05-21得票数 1
回答已采纳
此代码记录RxJS 4和RxJS 5的不同结果。
Rx.Observable.merge( Rx.Observable.from([1,2,3,4]), Rx.Observable.from([5,6,7]) ).subscribe(i => console.log(i))
RxJS 4的结果: 1,5,2,6,3,7,4 -根据合并文档，结果是正确的：
创建一个可观察到的输出，并发从每个可观察的给定输入中发出所有值。
RxJS5: 1,2,3,4,5,6,7 -结果与docs中描述的concat操作符相同
那么，如何在RxJS5中同时获得两个数组可观测值？
浏览 0提问于2018-01-26得票数 0
4回答
在角度1.x中，我有时需要发出多个http请求，并对所有响应进行处理。我会将所有的承诺都抛到一个数组中，并调用Promise.all(promises).then(function (results) {...})。
Range2最佳实践似乎指向使用RxJS的Observable代替http请求中的承诺。如果我从http请求中创建了两个或更多不同的可观测值，是否有与Promise.all()等效的？
浏览 5提问于2016-02-24得票数 113
回答已采纳
我今天有个棘手的问题。
在过去的一周里，我一直在与RXJS和可观察到的打交道，遇到了一个难题：Forkjoin()
我喜欢它是如何等待直到所有给定的可观测值发出一个值，然后继续做它的事情。但我不喜欢的是，它需要给定的观测量才能真正完成。
这样就很难使用需要重新单击的按钮(例如，执行多个请求)。
我会使用CombineLatest()，但这将使两个流相互独立地传递请求(一个可能比另一个快得多，这是不想要的行为)。
，所以我的问题是：
是否有可能在未完成底层可观测数据的情况下发射forkjoin()？
如果不是，是否有可能以某种方式重用已完成的可观察到的？
我现在将提供代码：
import {
浏览 9提问于2022-10-12得票数 0
假设我有以下两个对象：
obj1 = {
dataId: 1,
item: {}
}
obj2 = {
id: 1,
data: { a: 1, b: 2, c: 3 }
}
然后，我有两个可观察的对象，它们包含上述类型的对象数组：
Observable<obj1[]>
Observable<obj2[]>
是否有一种方法使用rxjs将两个可观测数据合并成一个新的可观测值，其中如果in是相等的，那么obj2的数据将映射到对象1中的item字段？因此，在上面的物体上，得到一个可以观察到的物体：
newObj = {
id: 1,
item: {
浏览 4提问于2016-10-10得票数 0
回答已采纳
1回答
我知道有些运算符会自动完成，如forkJoin，但据我所知，还有一些运算符从未完成，必须取消订阅以防止任何订阅泄漏，如combineLatest。
是否有一个好的方法来区分哪些必须取消订阅，哪些是安全的？或者至少有一份完整的名单？我很难从文档中得到这些信息。
我对RxJS还很陌生，所以如果我好像误解了什么，请告诉我。
请注意:我知道如何使用| async，但我正在处理一个现有的项目，在这一点上，使用它不是一种选择。我还知道并正在使用takeUntil代替unsubscribe方法，因此这并不是指这一点。我只想知道在使用了一个takeUntil运算符之后，何时需要使用RxJS / unsubs
浏览 3提问于2020-09-09得票数 1
回答已采纳
我用exhaustMap研究Rxjs，但它是高阶可观测的。我的例子只是简单地向db添加一行。有没有其他方法，因为我不使用高阶
浏览 20提问于2021-10-04得票数 2
我正在试图映射httpclient的结果，我们需要使用RxJ的新导入来实现树搜索。
所以我找到了两张地图但都没有用..。
import { map } from 'rxjs/operator/map';
import { map } from 'rxjs/operators/map';
我们需要去除的旧时尚方式
import 'rxjs/add/operator/map';
这是我要开始工作的代码！
getValues(): Observable<Value[]> {
return this.http.get<
浏览 2提问于2018-03-12得票数 4
回答已采纳
1回答
Rxjs大理石测试
、、、
试图了解单元测试RXjs 5订阅的最佳方法是什么。因此，例如，如果我有一个复杂的可观察链和订阅块中的一些业务逻辑，我应该如何测试它？我看到的选择是：
在advanceBy运算符中使用测试调度器(类似于在rxjs 4中这样做)
大理石测试，但据我所知，大理石测试只涵盖可观测的范围，这样您就可以根据特定的输入测试可观测链的输出，但是这个测试不包括订阅块.
任何建议或想法都会很有帮助。
浏览 3提问于2018-02-18得票数 1
回答已采纳
概述
遵循容器->组件模式，并使用ngrx来集中应用程序状态。
应用程序结构如下所示：
Container
Child_Comp_1
Child_Comp_2
Child_Comp_3
最初，容器上订阅的数据只有一个可以观察到，然后相关数据作为输入传递给子组件。比如
Observable<
{
data,
collection: []
}>
但是，任何更新都会触发ngrx选择器，并导致组件链中的AngularJS重新呈现。
我们开始为可观察的人服务，
Observable<
{
data: Observabl
浏览 3提问于2017-11-22得票数 0
2回答
所以，我有三个独立的观察：
ngOnInit(){
first$.subscribe(val => console.log(val));
second$.subscribe(val => console.log(val));
third$.subscribe(val => console.log(val));
}
这是不好的做法，没有结合上述可观察到的？我是RxJS的新手，有很多组合运算符，比如combineLatest，我会使用这些运算符，但在这种情况下，我只想使用console.log新值：
ngOnInit(){
combineLates
浏览 4提问于2020-10-26得票数 1
回答已采纳
2回答
用rxjs实现指数退避
、、、、
Range7 提供了rxjs Observable在实现AJAX请求的指数退避方面的实际使用示例：
import { pipe, range, timer, zip } from 'rxjs';
import { ajax } from 'rxjs/ajax';
import { retryWhen, map, mergeMap } from 'rxjs/operators';
function backoff(maxTries, ms) {
return pipe(
retryWhen(attempts => range(1,
浏览 0提问于2018-10-26得票数 10
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
