RxJS exhaustMap的行为与预期不符
RxJS exhaustMap是一个操作符，它用于处理Observable序列的转换和组合。它的行为是当源Observable发出一个值时，它会忽略其他的值，直到内部的Observable完成后，才会接收下一个值。
具体来说，exhaustMap会将源Observable发出的每个值映射成一个内部的Observable，并且只会订阅并发出内部Observable的值，而忽略其他值。如果在内部Observable还未完成之前，源Observable发出了新的值，那么这个新值会被忽略，直到内部Observable完成后才会接收新的值。
exhaustMap的应用场景包括但不限于以下几个方面：
- 处理用户输入：当用户频繁输入时，可以使用exhaustMap来忽略中间的输入，只处理最新的输入，例如搜索框的自动补全功能。
- 防止重复请求：当需要发送多个请求，但只关心最新的请求结果时，可以使用exhaustMap来忽略之前的请求，只发送最新的请求。
- 顺序执行任务：当需要按照一定的顺序执行一系列任务时，可以使用exhaustMap来确保每个任务在前一个任务完成后才执行。
在腾讯云的产品中，没有直接对应exhaustMap的特定产品或服务。然而，腾讯云提供了一系列与RxJS类似的响应式编程库和工具，例如腾讯云函数（SCF）和腾讯云消息队列（CMQ），可以用于实现类似的功能。
腾讯云函数（SCF）是一种事件驱动的无服务器计算服务，可以将函数作为服务运行，响应各种事件触发。通过使用SCF，可以将exhaustMap的行为模拟为一个函数，当触发事件时执行相应的逻辑。
腾讯云消息队列（CMQ）是一种高可靠、高可用的消息队列服务，可以实现消息的发布和订阅。通过使用CMQ，可以将exhaustMap的行为模拟为一个消息队列，当消息发布时执行相应的逻辑。
总结：RxJS exhaustMap是一个用于转换和组合Observable序列的操作符，它的行为是忽略源Observable发出的值，直到内部的Observable完成后才接收下一个值。在腾讯云的产品中，没有直接对应exhaustMap的特定产品或服务，但可以使用腾讯云函数（SCF）和腾讯云消息队列（CMQ）等相关服务来实现类似的功能。
相关·内容
我正在将exhaustMap应用于一个可观测对象，由此可以创建两个投影的可观测对象。两个投影的观测点中的第二个在第一个投影的观测点完成之前不应该开始发射。因此，我期望输出可观测值会从两个投影的可观测值中发出项。但出于某种原因，第二个观察点被忽略了。请注意，第二个投影的可观测对象直到7秒后才开始发射--这远远超过了第一个投影的可观测对象发射其最后一项的时间点。下面是我的代码示例： import { from } from 'rxjs';
import { interval } from 'rxjs';
import { take } from 'rxj
浏览 14提问于2021-09-14得票数 1
回答已采纳
我一直试图在Redux可观察和Redux操作中正确地使用rxjs。我尝试了许多不同的组合来调用以下函数，而每一个可能的组合都给了我不同的错误。
基本上，我有两个可以在我的应用程序中执行的操作：SET_CIRCULAR_DATA和SET_MODAL_OVER_DEEP_LINK_FLAG。
我想要分派另一个操作，当determineFoundInProducts()发生时，SET_MODAL_OVER_DEEP_LINK_FLAG会发生，然后是第一个(成功的) SET_CIRCULAR_DATA操作。任何后续的SET_CIRCULAR_DATA操作都应该被忽略，直到SET_MODAL_OVER_
浏览 0提问于2018-06-16得票数 0
回答已采纳
我将一个Promise作为参数传递给Subject：
const work = new Subject<{ id: number; dialogRef: Promise<typeof Dialog> }>();
我希望稍后在promise中使用该实例：
...
exhaustMap(({ id, dialogRef }) =>
http.get({ id }).pipe(tap(() => dialogRef.close()))
)
...
但是问题是dialogRef是一个Promise，我需要在使用实例函数(close())之前解决它。
我能够做到的
浏览 4提问于2022-08-21得票数 -2
我对rxjs很陌生，我想做一个简单的特性，让每个点击事件都发送一个ajax，当prev没有响应按钮时，只返回一个按钮
在纯js中，我只是设置了一个标志来检查ajax是否已完成，但我知道如何在rxjs中执行此功能。
纯js代码，如
let flag = false;
let el = document.querySelector("#btn");
el.addEventListener("click",handleBtn);
let handleBtn = () => {
if(flag) return; // if ajax no response
浏览 0提问于2018-09-28得票数 0
回答已采纳
我已经开始深入学习RxJ，其中一个原因是掌握了redux-observable副作用方法，因此我发现sagas更方便和“声明性”。我已经学习了merge/flat/concat/switchMap操作符，但它并没有帮助我弄清楚如何在rxjs中排序。
这里有一个我所说的“排序”的例子，在计时器应用程序中，开始可能在一段时间后被排定，用redux-saga实现
export function* timerSaga() {
while (true) {
yield take('START');
const { startDelay } = yield selec
浏览 4提问于2020-03-27得票数 0
回答已采纳
你好,
首先，感谢您阅读这篇文章。
我想处理滚动事件流，我想在滚动开始时做出反应，并忽略随后的滚动事件突发，直到流被认为是不活动的(时间限制)。所以在延迟之后，我想重复同样的话。
这是我到目前为止的解决方案：
import { fromEvent } from 'rxjs';
import { throttle, debounceTime } from 'rxjs/operators';
const stream = fromEvent(window, 'scroll');
const controllerStr
浏览 0提问于2020-04-27得票数 1
我用exhaustMap研究Rxjs，但它是高阶可观测的。我的例子只是简单地向db添加一行。有没有其他方法，因为我不使用高阶
浏览 20提问于2021-10-04得票数 2
我有这样的方法通过本地存储获取令牌，如果令牌不存在或过期，我将调用API来获取另一个令牌并将其存储到本地存储。
在这种情况下，我应该使用哪个映射，目前使用的是mergeMap，还是其他方法？
public doGetToken():Observable<Token> {
return this.loadToken().pipe( //get via localstorage
map(token=>{
let valid = this.validateTokenIsValid(token);
let data = {
浏览 1提问于2018-07-04得票数 2
回答已采纳
我有一个模块，客户端从服务器侦听websocket事件，每次收到更新事件时，都会发出HTTP调用来更新UI上的数据集。我遇到了一个问题，对于某种类型的操作，服务器在10秒内发送大约40个更新事件，UI在10s的范围内触发40个API调用。服务器似乎无法处理所有这些请求。
我想知道是否有一种rxjs方法来处理这个问题，当对服务器的API调用仍然对同一个请求挂起时，我必须等待它完成才能再次发出相同的请求。
listen(wstopic) {
return this.wsService.subscribeEndPoint(wstopic).pipe(
switchMap((even
浏览 11提问于2022-08-02得票数 0
回答已采纳
1回答
考虑到我有以下代码：
private readonly postAction$ = new Subject();
postStream$ = this.postAction$.pipe(
exhaustMap(() => {
this.count ++;
console.log('fired')
return of('my other post');
}),
startWith(''),
exhaustMap(()=> {
this.count ++;
浏览 4提问于2019-10-30得票数 2
回答已采纳
1回答
当涉及到rxjs时，我认为自己相当精明，但我不知道自己做错了什么。我正在尝试通过将我的用户登录转换为效果来学习ngrx。我的效果正在正确地触发，并且从我的服务器返回正确的令牌响应(通过登录控制台验证)，但在我的效果中地图操作符从未被触发。
下面是我的效果代码：
@Injectable()
export class UserEffects {
constructor(
private authService: AuthService,
private actions$: Actions
) { }
@Effect() loginUser$ = this.actions
浏览 0提问于2018-05-29得票数 2
我正在尝试实现Firebase身份验证，并将收到的用户数据发送到服务器，以便在我的应用程序中创建帐户。
代码如下：
ngAfterViewInit(): void {
const provider = new firebase.auth.GoogleAuthProvider();
fromEvent(this.LoginWithGoogle.nativeElement, 'click')
.pipe(
exhaustMap(() =>
from(this.afAuth.signInWithPopup(
浏览 1提问于2021-03-16得票数 2
RxJS版本2.2.26中的
下面的代码产生了一个流，它将发出点击次数(双击、三次单击等)。
var multiClickStream = clickStream
.buffer(function() { return clickStream.throttle(250); })
.map(function(list) { return list.length; })
.filter(function(x) { return x >= 2; });
RxJS版本4.0.6中的
此代码不再生成所需的结果。
如何在RxJS 4.0.6中获得相同功能？
浏览 68提问于2016-05-19得票数 8
回答已采纳
2回答
一个角度的RxJS代码发出一个API调用，从一个API服务中获取信息，但是，我需要每秒钟发出一个请求。我知道我需要使用可观察的，但不知道如何进行。
浏览 6提问于2022-06-02得票数 0
我需要在函数结束后每5000ms调用一次函数。我如何才能做到这一点。 我目前的实现只是保持每5000毫秒调用一次，即使函数需要更长的时间 const { BehaviorSubject, timer} = require("rxjs");
const subject = new BehaviorSubject(false)
async function doit() {
console.log('hey')
subject.next(true)
}
timer(0, 5000).subscribe(() => {
doit
浏览 45提问于2021-10-02得票数 0
回答已采纳
我正在寻找类似于来自rxjs的rxjs运算符的东西，但是RX.NET似乎没有这样的运算符。
我需要实现的是，在源流的每个元素上，我需要启动一个async处理程序，在它完成之前，我希望从源代码中删除任何元素。一旦处理程序完成，请继续接受元素。
我不希望在每个元素上启动一个异步处理程序--当处理程序运行时，我希望删除源元素。
我也怀疑我需要聪明地使用这里的延迟操作符？
谢谢!
浏览 0提问于2020-10-14得票数 6
回答已采纳
3回答
我试着发送http请求。我使用了角2和rxjs库。我需要在5秒内发送请求。
首先，我导入操作符并使用它：
import { Injectable } from '@angular/core';
import { HttpClient } from '@angular/common/http';
import { Observable } from 'rxjs/Observable';
// import { interval } from 'rxjs/observable/interval';
import 'rxjs/a
浏览 3提问于2017-12-12得票数 2
回答已采纳
我们有一个计时器，例如每2秒滴答一次，只要有滴答声，我们就打一个http电话。响应时间不同，可能是100 ms，但可能是4秒。问题是，只有当上一次调用完成时，我们才进行新的http调用。所以我们有两个病例：
#1如果每个http调用花费10秒时间，我们应该每10秒只发送一个请求。
如果每个http调用花费100 If，我们应该每2秒发送一个请求。
在这个场景中，同样困难的是getHttp调用依赖于来自interval$流的值。
到目前为止，我想出的最好的解决方案是：
import { of, interval, timer, combineLatest, BehaviorSubject } f
浏览 4提问于2022-11-30得票数 0
我正在努力处理一个我希望使用RxJS的特定场景：
对于要注册的值，应按顺序触发两个可观察对象：
表示用户按下按钮的可观察对象表示设备返回其下一个值的可观察对象
用户按下按钮后，应等待设备返回下一个值，然后捕获并处理该值。在此之后，它应该再次等待相同的事件序列。
我发现如果我使用concat，它只工作一次，并且我在接收到按钮动作和设备的值时完成了观察值。
但是，在观察对象完成后，我不能再将它们用于后续操作。
我还发现我可以使用zip，它将在两个可观察对象返回它们的next()之后触发，但这样就不能保证顺序(按钮被按下后它不会返回next值，它将发出同时发出的值)。
对于这种情况，最佳实践解决方案
浏览 70提问于2019-04-12得票数 0
回答已采纳
1回答
很抱歉，如果这个问题的措辞不好，那是因为我找不到合适的词来描述它。
我正在做一些硒自动化，流程如下：-
导航到页面，间隔1秒，如果页面包含元素，检查页面是否包含元素，刷新页面，如果没有，请返回到步骤2，等待页面完成重新加载，然后重复步骤2
这就是我想出来的：-
interval(1000)
.pipe(
switchMap(() => from(driver.findElements(By.xpath("elementx"))),
filter(([element]) => element), // finish if no element found, wai
浏览 2提问于2021-01-03得票数 0
回答已采纳
为什么我失去了我的pipe函数的类型？怎么解决这个问题？
类型'{}‘上不存在属性'n’
import { of, map, Observable, Subject, pipe, tap } from 'rxjs';
import { exhaustMap, withLatestFrom } from 'rxjs/operators';
const action = new Subject<{ n: number }>();
const id$ = of(1);
const bar = () =>
pipe(
浏览 3提问于2022-05-12得票数 0
1回答
import {
HttpHandler,
HttpInterceptor,
HttpParams,
HttpRequest,
} from '@angular/common/http';
import { Injectable } from '@angular/core';
import { exhaustMap, take } from 'rxjs/operators';
import { AuthenticationService } from './authentication.service';
@In
浏览 3提问于2022-11-15得票数 -1
回答已采纳
1回答
我想用rxjs实现一个进度条，所以我需要在我编写的测试代码mousedown.here之后得到鼠标向下的位置和mousemove的位置。
useEffect(() => {
const start$ = fromEvent(divRef.current, 'mousedown').pipe(
tap(() => console.log('start')),
map(event => [event.clientX, event.clientY])
)
const move$ = fromEvent(divRef.current, '
浏览 7提问于2022-05-09得票数 0
1回答
创建一个De弹跳指令，其中我最终限制了单击事件，或者您面临的问题是我的按钮有发送事件之前.例如：
<button class="btn btn-light btn-block" type="submit" [hidden]="formCadastrohabilitado">
<i class="material-icons center align-middle ">
浏览 3提问于2020-02-20得票数 0
回答已采纳
1回答
下面是我们想要使用并仅使用RXJS Observables的简单过程
单击“登录”按钮(带有用户名和密码的表单)。Observable.fromEvent与我们的表单绑定。
提交表单后，调用loginUser()，它向服务器发送http请求并返回可观察的结果。
如果HTTP请求正在进行:单击“登录”按钮不应触发另一个登录请求。
如果HTTP请求没有进行:单击“登录”按钮将触发另一个登录请求。
take(1)，takeUntil()，takeLast()没有帮助我们。那么，如果我们在500 is中单击login按钮5次，并在loginUser()完成后再次使其可用，那么停
浏览 0提问于2016-05-06得票数 0
回答已采纳
我有一个带有CreateReviewForm的reCaptcha，我为它提供了3个流：
ngRx action (addReview) (第一可观测)。每次触发此操作时，我都必须调用this.recaptchaV3Service.execute()方法，该方法使用令牌(string) (第二个可观测的)返回可观察的。然后，使用此标记，我必须调用API方法来创建评审observable)，该方法返回通过创建的审查(第3次)可以观察到的结果。
首先，我在combineLatest上尝试了它，但它并没有像我预期的那样起作用。方法，仅当我第一次单击"Add“btn时才获取令牌发射值。接下来的所
浏览 13提问于2022-06-12得票数 1
1回答
我有一个能自动保存的角形。保存功能有几个部分，可能需要一些。根据表单值的变化触发保存。
显然，我可以使用可观察到的方法来消除表单值的更改，但是如何防止多个保存调用同时发生呢？
我想要的：
在保存完成之前，用户更改了一些输入fieldsAuto-save并采取了2s，用户更改了更多字段代码等待当前保存操作完成，然后触发另一个保存调用--只有一个，即使有几个字段超出了崩溃限制进行了更改。
我一直在研究RxJS文档，但是它很复杂，我找不到适合我的用例的任何东西。我知道我可以组合运算符，但我不确定该合并哪些操作符和/或如何组合。有一个the ()操作符，它需要另一个可观察的，但这似乎只是一个可观察的，
浏览 3提问于2022-07-06得票数 0
我有一个RxJS Subject<boolean>，用于控制旋转器是启动(true)还是停止(false)。
我试图在RxJS中实现以下行为：
当我启动旋转器时，我希望它至少运行500 to ，即使在此之前收到了停止事件。用RxJS术语:当我在我的主题上发出一个true值时，计时器应该启动500 my，在这个主题上发出的所有false值都应该被忽略，直到计时器过期。
我希望旋转器在10,000 ms之后自动停止，即使没有收到停止事件。用RxJS术语:当我在我的主题上发出一个true值时，另一个定时器应该启动10000 my，当这个定时器过期时应该发出一个false值。
浏览 1提问于2019-10-05得票数 1
当前行为:我已经创建了一个HttpInterceptor，它为所有请求设置一个id和令牌，如果用户凭证可供获取的话。当我试图在请求中设置额外的HttpParam时，它会被拦截器覆盖。 预期行为:如果需要，我希望能够设置额外的参数，并让拦截器附加默认的id和令牌。 我知道为什么行为是这样的，但是有没有办法让拦截器设置http参数并附加任何额外的请求参数？ import {
HttpEvent,
HttpInterceptor,
HttpHandler,
HttpRequest,
HttpParams,
} from '@angular/common/http'
浏览 42提问于2021-01-20得票数 0
回答已采纳
我有一个按钮，可以调用HTTP请求并从服务器获取数据。现在，当之前的HTTP请求未完成时，我希望停止多次单击该按钮。 我可以通过使用RXJS库中的exhaustMap运算符来实现此结果。 因此，它只在第一次点击时工作，在HTTP请求成功或错误后，在另一次点击时，它根本不工作。 我该如何解决这个问题？ HTML <button #rescheduleButton type="button" class="btn btn-primary">
Get Data
</button> 打字脚本 @Vie
浏览 9提问于2019-09-11得票数 0
在我的项目中，我有一个带有验证按钮的反应式窗体，我想防止后端的多次点击和多次调用。 所以我用component.html做了这个 <button #boutonValider></button> 在component.ts中 @ViewChild('boutonValider', { static: true }) boutonValider: ElementRef;
ngAfterViewInit() {
this.validationCreationDecision();
}
validationCreationDecision() {
浏览 15提问于2021-04-30得票数 0
回答已采纳
我不喜欢像by ngrx这样的官方指南。我想为auth创建我的第一个存储对象。我想，如果我从logout逻辑开始，我可以更好地理解逻辑并提高我的技能。 作为零步骤，我为http请求http-auth.service.ts创建服务 import { HttpClient, HttpErrorResponse } from '@angular/common/http';
import { Injectable } from '@angular/core';
import { throwError, Observable } from 'rxjs';
浏览 5提问于2020-05-03得票数 0
我需要创建一个具有缓冲区的事件管理器，如果满足以下三个条件之一，该缓冲区就会刷新：
2秒通过
收到50项活动
用户要求时按需冲水
当缓冲区刷新时，所有条件都会重置(重置2秒计时器，重置50个事件count...etc)
到目前为止，这就是我所实现的，它似乎正在起作用，但我想知道是否有更好的方法来实现这一要求。
import { interval, merge, Subject, Subscription } from "rxjs";
import { bufferWhen, filter, tap } from "rxjs/operators&#
浏览 14提问于2022-09-02得票数 0
1回答
我有一个非常简单的服务器轮询场景：
call API -> 2. onSuccess -> 3.等待500 go -> 4.回到步骤1
和
call API -> 2. onError -> 3.完成
我想使用rxjs，因为我已经使用了rxjava。但我似乎无法找到合适的解决方案来解决问题。我尝试过计时器和间隔，但问题是它们只是无限地运行，没有处理程序在等待服务器响应或错误发生时完全退出时暂停它们。试着使用retryWhen，但根本无法让它工作。
这就是我想要的：
downloadData() {
console.log('downloadin
浏览 6提问于2019-12-26得票数 0
回答已采纳
有人，请解释一下SwitchMap和FlatMap在Javascript上的区别(从角度上看，rxjs 5)。
据我理解。
SwitchMap只发布最新的可观测值，并取消以前的可观测值。
flatMap收集所有单个可观测数据，并在一个数组中返回所有可观测数据，而不关心可观测的顺序。异步工作。
concatMap保持顺序并发出所有可观测值，同步工作。
是那么回事吗？
mergeMap是如何与上面的工作方式不同的？
有人，请举例说明。
浏览 5提问于2018-04-06得票数 112
回答已采纳
1回答
我对ngrx世界很陌生。
我正试图从我的影响中直接得到我的状态数据。
其想法是获得一种类型的帐户(出版商或广告商)，并将这些信息发送到一个“成功”的行动。
这是我的功用：
import { Injectable } from "@angular/core";
import { map, exhaustMap, withLatestFrom } from 'rxjs/operators';
import { Actions, createEffect, ofType } from '@ngrx/effects';
import { AuthServ
浏览 10提问于2022-06-03得票数 -1
是否可能只运行startWith一次？
在我的中，我有一个触发Subject的按钮。
在constructor中，为了获得结果，我订阅了Subject。
在Subject的管道中，我以4秒的延迟返回结果(HTTP假)。
我还添加了startWith来传递订阅函数pending: true的值，并最终得到了值为pending: false的endWith。
通过传递对象而不是回调函数，我喜欢{ pending: true }和{ pending: false }的这种语法。
但是如何使startWith只发生一次呢？有可能吗？我不想每次都有pending: true。只有一次。
import {
浏览 9提问于2022-03-30得票数 -1
我正在用RxJS做分页器，我在调用新页面时使用一个主题来集中处理。在每个事件中，我都使用exhaustMap检索页面。这可以防止同一页面多次触发getPage http调用。
this._nextPage$.pipe(
exhaustMap(nextPageNumber => this.getPage(nextPageNumber))
).subscribe();
但是我也想在每个http挂起上显示一个旋转器。
使用此代码的，如何到达合并的http可观察到的订阅? (以便将挂起的组件绑定到订阅)
提前行动！
编辑
由于以下两个主要原因，我需要/更喜欢使用保存挂起状态本身的订阅：
浏览 1提问于2018-03-29得票数 0
//app.effect.ts
import { Injectable } from '@angular/core';
import { Actions, createEffect, ofType } from '@ngrx/effects';
import {addCityToIndex, returnCityToIndex} from './reducers/form.reducer';
import { map } from 'rxjs/operators';
import { HttpService } from
浏览 35提问于2021-09-21得票数 0
角: 14.0.1，rxjs: 7.5.0
因此，我得到了一个可观察的类似于user$ = http.get('/user')的ngOnInit，它与.pipe(shareReplay())共享，这样就不会被调用为不必要的，特别是在使用和异步管道{{(user$ | async)?.name}}时。
在使用http请求修改用户之后，我希望加载用户以显示其新值。为此，我使用在PUT请求的结果中触发的重新加载主题。
this.put('/user').subscribe(() => this.myService.sendReload()):
我听reloadR
浏览 1提问于2022-10-11得票数 1
我正试着把我的头伸向RxJS。特别是，我有一种情况，我试图通过一个过滤器，通过一个内部可观测谓词，依赖于外部可观测到的输出，从外部观测到的排放管道。举个例子：
outerObs.pipe(
filter(x => myPredicate(x))
).subcribe()
其中mypredicate是一个返回Observable<boolean>的函数。显然，上面的操作不工作，因为filter操作符需要一个boolean，而不是Observable<boolean>。有什么好的方法可以做到吗？我试过查看withLatestFrom和mergeMap运算符，但
浏览 0提问于2019-05-03得票数 3
回答已采纳
我是个响应式编程新手。我只是想了解一下观察值和rxjs运算符。我有一个react-redux应用程序，它有一个自定义中间件来处理缓存数据和isFetching标志。虽然它只处理我需要的事情，但对于取消或去抖动之类的事情，它可能会很复杂。因此，我想将此应用程序迁移到redux-observable。 我不想获取相同的电影，如果它当前正在获取。我只是将一个selectIsFetchingMovieById(action.movieId)选择器传递给自定义中间件。如果它返回true，则不会将任何内容传递给reducers。但是当选择器返回false时，它会获取电影，运行.then或.catch，就
浏览 27提问于2019-10-11得票数 0
回答已采纳
1回答
我在使用rxjs实现无限滚动时遇到了问题
我已经尝试了以下代码片段
var lastid = null
fromEvent(window, 'scroll')
.pipe(
filter(() => isAtPageBottom()),
exhaustMap(() => from(this.getList(lastid))),
takeWhile(list => list.length !== 0),
scan((cur, list) => [...cur, ...list], [])
)
.subscribe
浏览 5提问于2019-07-08得票数 0
如果将与更复杂的RxJS运算符(如switchMap或exhaustMap )一起使用，而不订阅订阅块中的可观察对象，那么最佳实践是什么？
如果您在this.busy上设置了BehaviorSubject，那么它总是很忙，因为它要离开BehaviorSubject，而不是Http请求订阅。
public currentPage$ = new BehaviorSubject(1);
// ...
// Not sure how to use "busy" this way:
this.currentPage$
.pipe(
exhaustMap((page: nu
浏览 2提问于2018-10-13得票数 2
2回答
如何按照这些标准使用rxjs进行自动保存？
单击“保存”按钮应发出http请求以保存我的数据(来自局部变量，而不是表单)。
每3000毫秒(间隔)应该做同样的我点击按钮。
不能是并行http请求。在请求处于活动状态之前，另一个请求在完成之前不应该运行。如果请求开始，那么所有其他请求都应该在队列中等待(然后逐个执行)。
保存按钮应该在队列/执行中获得高优先级。
我想使用rxjs的强大功能，所以最好由rxjs操作符而不是局部变量(if (this.requestStart === true))来实现。
这是我想要完成的。任何帮助都将不胜感激
import { Compone
浏览 0提问于2019-03-15得票数 0
2回答
我有以下效果，在一种情况下，我想以管理员身份登录，在第二种情况下，作为普通用户登录。
signIn$ = createEffect(() =>
this.actions$.pipe(
ofType(AuthActions.signInRequest),
exhaustMap(({ variables, redirectTo, hasAdmin }) => hasAdmin ?
this.authService.signInAdmin(variables) :
this.authService.signIn(v
浏览 3提问于2021-03-09得票数 0
我有一个效果函数，在这个函数中，我试图将数据从分派的操作和单独的选择器传递到服务中的函数，但是我在RXJS语法中迷失了方向。我很确定我没有正确地映射数据。请看相关代码。
//影响
updateCohort$ = createEffect(() =>
this.actions$.pipe(
ofType(getCohortActions.updateActiveCohort.type),
withLatestFrom(this.store.pipe(select(activeCohort))),
map(([action, sele
浏览 5提问于2020-02-12得票数 1
回答已采纳
2回答
我们可以在构造函数中使用http可观测和订阅方法吗？它的优点和缺点是什么？如果我们将rxjs代码放入构造函数中，那么角生命周期是如何工作的
浏览 8提问于2022-10-01得票数 -1
2回答
我希望遍历对象数组中的it，然后将其传递给另一个操作。我尝试了data.foreach，但我得到了一个错误。很可能我没有使用正确的RXjs运算符。在这方面的任何帮助都将受到高度的感谢。 示例data= {id:1，name：'name1'}，{id:2，name：'name1'} loadSucces$ = createEffect(() =>
this.actions$.pipe(
ofType(Actions.loadSuccess),
switchMap(([d
浏览 5提问于2020-04-01得票数 0
回答已采纳
1回答
我在我的角项目中有这个RxJS代码：
settingsService.getSetting('setting-name').pipe(
map((setting: SettingInterface) => {
// ...
return setting;
}),
tap((setting: SettingInterface) => this.settingService.save(setting)),
map((setting: SettingInterface) => {
// ...
})
);
在这段代码中，
浏览 1提问于2020-07-24得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
