我有一个发送AJAX请求的函数。我想忽略这个函数的额外调用，如果它们发生得太频繁的话。我可以使用auditTime()运算符： const requestStream$ = new Subject<IRequestOptions>();
.pipe(auditTime(1000) // no more than 1 time in 1 second.subscribe(requestOptions => {
// sen
浏览 15提问于2019-05-22得票数 1
回答已采纳
我正在尝试订阅带有角异步管道的BehaviourSubject/ReplaySubject。此外，我还必须使用auditTime或debounceTime运算符来丢弃一些值。下面是一个示例(我使用了RangeCLIVersion7.3.0并仅更改了app.component )：import {Component, OnInit} from '@angular/core';
import {Observable, ReplaySubject, Subject} from &#x
浏览 1提问于2019-03-08得票数 1
回答已采纳
按照rxjs的文档和不同的指南页，不能解决debounceTime不工作的问题。function getValue() { let counter = 0; }, 100);}
getValue().pip
浏览 3提问于2018-07-16得票数 1
回答已采纳
3回答
示例Plunkr：auditTime()、throttleTime()和debounceTime() .throttleTime(500)
.subscribe((value) => doNext
浏览 5提问于2016-05-10得票数 21
回答已采纳
我使用RxJS的.auditTime(500)操作()作为尾随节流:我希望每500 ms最多发出一次服务器调用。当服务器调用完成后，我需要询问是否有更多挂起的服务器调用，或者缓冲区目前是否已清除，以便以“保存…”等状态消息的形式将此信息传递给用户。还有“得救”。 .do(() => { setStatus(Status.SAVIN
浏览 6提问于2017-09-25得票数 2
回答已采纳
2回答
我研究并想出了这个解决方案：const { Subject } = require('rxjs/Subject')function makeRe
浏览 1提问于2017-11-02得票数 2
回答已采纳
2回答
我想避免多重订阅的反模式。我正在纠结于RxJs语法，以及该怎么做(forkJoin、mergeMap等)。
我如何重构这些，以删除订阅中的订阅。
浏览 0提问于2019-07-19得票数 1
results$ = new BehaviorSubject(null); 比方说我订阅了这个 this.results$.subscribe(() => this.find()); 每当我在输入元素内部的键盘上按下任何键时因此，为了防止对服务器的大量请求，我添加了debounceTime() this.results$ .subscribe(() => this.find
浏览 19提问于2020-08-16得票数 2
回答已采纳
3回答
RxJS减少不会继续
、、、
为什么flatMap不引起下游的减少呢？handleFiles.flatMap(files =>).问题是‘后减少’的水龙头永远不会被击中日志是这样的：reduce step
浏览 2提问于2015-11-08得票数 7
回答已采纳
我在RxJS 5 (beta10)中使用。我的大部分事件来自鼠标或触摸拖动，我只需要听到最后一个。似乎很好地总结了RxJS5背压的</em
浏览 3提问于2016-07-25得票数 1
如果在同一时间多次调用此函数，则它不应向服务器发出许多相同的请求。它只能发出1个请求。我想为了这个目的，我可以使用RxJS库。const response$ = request.pipe( flatMap(group => group.pipe(auditTime在request$流中还有groupBy和auditTime运算符。和doAJAX函数中的过滤运算符。 这段代码可以工作，但我认为它非常困
浏览 16提问于2019-05-24得票数 2
回答已采纳
我找不到与此相关的帖子，也无法从文档中找出细微之处，auditTime和sampleTime操作符之间有什么区别？
浏览 0提问于2020-05-02得票数 4
回答已采纳
我有两个操作，a.load和b.load，在它们的后面注册了@effect来对c执行HTTP调用。但是，在页面加载时，a和b操作都被分派，结果是请求c两次，就会出现问题。我需要对这两个操作做出反应的原因是，在这个页面上，a或b可以更改，如果是这样的话，我需要执行一个请求来获得c的新值。谢谢。
浏览 4提问于2017-02-08得票数 1
回答已采纳
1回答
我正在尝试测试使用.subscribe方法的angular4 4/typescript单元测试中的一个rxjs auditTime块内的值。我读过很多类似的帖子，似乎没能让我进入那个街区。而且我没有遗漏一些非常明显的东西--这就是为什么我的测试没有提供正确的结果--我尝试用以下的想法修改我的测试：spyOn(component.form.
浏览 1提问于2019-02-02得票数 1
回答已采纳
2回答
在RxJS中，像auditTime和throttleTime这样的过滤器在某个持续时间过去之后(以不同的方式)发出一个可观察的。我需要发出一个可观测的，然后等待一段时间，然后发出下一个值。就我而言，我的工作是棱角分明的。例如，这段代码：不会完成我所需要的</em
浏览 2提问于2019-01-28得票数 5
import { map } from 'rxjs/operators';和import 'rxjs/add/operator/map';有什么区别？我在执行登录的服务方法中使用它：import 'rxjs/add&
浏览 32提问于2018-09-04得票数 3
回答已采纳
2回答
我有一个Observable，它从用户输入(滑动块的偏移值)发出一个值流。因此，我想把退欧和流的定期“抽样”结合起来。现在我的
浏览 7提问于2017-08-20得票数 4
回答已采纳
1回答
此代码仅适用于第一次拖动，停止将不适用于连续拖放。const { takeUntil, switchMap } = rxjs.operators;
const mouseups
浏览 1提问于2018-06-06得票数 1
回答已采纳
假设我有一个如下所示的函数： counter: o$.pipe( ) pluck('target', 'value'), auditTime(300)})
如何使用现有的可观察对象
浏览 0提问于2018-08-19得票数 3
我已经成功地使用RxJS将更大的Excel计算迁移到JS。任何输入数据都表示为可观察的，当任何Excel公式使用多个输入时，随后的计算将使用.map和.combineLatest实现。下面是一个简化的示例：
三个输入(a$=1、b$=2、c$=3)用于两个不同的计算(第一个是$ab = $a+$b = 3，第二个是$bc = $b+$c = 5 )，作为中间步骤来计算最终结果$当$b现在被更新/释放一个新的输入值(例如4)时，$abbc
浏览 1提问于2016-11-06得票数 2
回答已采纳
云服务器
ICP备案
对象存储
云直播
腾讯会议
腾讯云开发者
