RxJS -结合使用fromEvent和switchMap时的奇怪行为
RxJS是一个流式编程库，用于处理异步数据流和事件流。它提供了丰富的操作符和工具，使开发人员能够轻松地处理复杂的异步场景。
在RxJS中，fromEvent操作符用于将事件转换为可观察对象。switchMap操作符用于将一个可观察对象转换为另一个可观察对象，并且只发出最新的可观察对象的值。然而，当结合使用fromEvent和switchMap时，可能会出现一些奇怪的行为。
这种奇怪行为的原因是，fromEvent操作符会为每个事件创建一个新的内部可观察对象，而switchMap操作符只会订阅最新的内部可观察对象。如果事件频率很高，那么可能会导致内部可观察对象的订阅和取消订阅频繁切换，从而导致一些意外的结果。
为了解决这个问题，可以使用debounceTime操作符来限制事件的频率，或者使用其他操作符来控制事件流的处理方式。另外，也可以考虑使用其他操作符替代switchMap，例如concatMap或mergeMap，根据具体需求选择合适的操作符。
在腾讯云的产品中，与RxJS相关的产品包括云函数SCF（Serverless Cloud Function）和消息队列CMQ（Cloud Message Queue）。云函数SCF是一种无服务器计算服务，可以用于处理异步任务和事件驱动的场景。消息队列CMQ是一种高可靠、高可用的消息队列服务，可以用于处理大规模的消息传递和事件驱动的场景。
了解更多关于云函数SCF的信息，请访问腾讯云函数SCF产品介绍页面：https://cloud.tencent.com/product/scf
了解更多关于消息队列CMQ的信息，请访问腾讯云消息队列CMQ产品介绍页面：https://cloud.tencent.com/product/cmq
相关·内容
当我从这个发射器创建一个可观察值并使用switchMap时，我得到了一些奇怪的行为，其中n值进入switchMap，但只有1出来。下面是一些简化的代码：
e, tap(v => console.log('pr
浏览 10提问于2019-11-20得票数 0
回答已采纳
import { map, switchMap, delay, tap, mapTo } from "rxjs/operators";
import { of, fromEvent } from "rxjs当按钮被快速点击几次时，我只想在最后一次点击后2秒显示"yayy“一次。 这是我的尝试，yayy永远不会出现。import { map, switchMap, delay, tap, mapTo } from &quo
浏览 17提问于2020-04-21得票数 0
3回答
考虑下面的示例：import { switchMap, tap } from 'rxjs/operators';
const httpCall$ = ajax.getJSON('https://rickandmortyapi.com/api/
浏览 1提问于2019-11-06得票数 1
我创建了一个类，它使用RxJS操作符设置一个可暂停的interval Observable： private pausedboolean) { } return observable;}
这似乎很好，但我试图解决的问题是，我希望计时器重置时，不暂停。因此，假设interval时间是interval上次
浏览 0提问于2019-04-16得票数 14
回答已采纳
per_page=5`))click$.pipe().subscribe在第一种情况下(s1$)，每次都收到相同的结果，尽管我不能理解为什么switchMap每次都不启动一个新的流，但对我来说它看起来很好。好的，很好 当你运行s2$和s3$时，真正的事情就发生了，看起来
浏览 13提问于2019-02-12得票数 0
回答已采纳
我正在尝试使用Rxjs和mousedown、mouseup和mousemove事件创建自己的单击、持有和拖动事件。我的尝试使用了一些以鼠标向下事件开始的流，每个流都有一个takeUntil来监听来自其他流的排放。我看过其他答案，并认为它可能与运行异步的计时器有关，但它发生在不依赖计时器的流之间，例如拖动和单击。我一直在codesandbox.io中使用</
浏览 0提问于2019-04-01得票数 0
我的目标是在1秒的间隔内再次发出"hi“，直到按键被按下，并在鼠标点击时继续。下面是我的代码： import { of, fromEvent, interval } from 'rxjs';
import { map, tap, takeUntil,take, repeatWhen, shareReplay, switchMap , takeLast} from 'rxjs/operators
浏览 45提问于2019-06-13得票数 2
回答已采纳
我的目标是在Ionic 3项目中使用RxJs switchMap，在服务器离线时取消任何正在进行的登录尝试，并且只使用最新的请求。否则，我可以得到一些不必要的异步副作用以后。在我的视图层中，我使用submitStream$捕获按钮单击流，然后将它作为方法参数传递给服务层。在服务层，我通过一个response$创建switchMap，将传递的参数submitStream$与从this
浏览 3提问于2017-09-01得票数 0
回答已采纳
这是我到目前为止所知道的： this.timer$ = fromEvent(document, 'mousemove')first(), switchMap做这件事的方法是什么？
浏览 30提问于2018-06-07得票数 1
我找到了一些代码来实现这一点，但不幸的是，这并没有按要求工作。当我搜索一个字符串时，它会发送多个http请求，但它应该只是一个http请求。这是我的代码。fromEvent(this.simpleSearchInput.nativeElement, 'keyup').pipe( switchMap
浏览 0提问于2019-03-29得票数 0
我正在使用PrimeNg库。它有很好的<p-dialog>组件，它在默认情况下创建可拖动的对话框。但是在特定的上下文中，我使用PrimeNg的API dialogService动态创建对话框。但在这种情况下，对话框是不可拖放的。
有什么办法让它起作用吗？
浏览 5提问于2019-10-25得票数 3
1回答
当我在左侧悬停时，该区域将像下面的图像一样向右移动，并会出现一些额外的文本。
我已经取得了一些接近它和它的CSS部分。
第一次加载时，可以看到50-50部分。然而，当我试图快速地在左右区域悬停时，它会触发多个事件，并以一些不受欢迎的行为结束，并在上进行模拟。{ fromEvent } from 'rx
浏览 0提问于2018-06-25得票数 0
我正在处理这个沙盒-- https://stackblitz.com/edit/rxjs-g7msgv?file=index.ts 我想要做的是： 1)等待onLogin事件 2)登录时，我想要重新connectSocket()，每当套接字断开连接，应用程序在前台时，我想要重新connectSocket(fromEvent(document, 'onLogin') switchMap(()
浏览 10提问于2019-04-28得票数 0
回答已采纳
大家好，我是RxJS的新手，我刚刚开始了解运算符。我想在点击按钮后，在控制台中显示下一秒间隔内的6个数字。我想在下一次点击后使用switchMap重置计数器。我一直在尝试使用switchMap，但是计数器没有重置。obsSwitchMap: Observable<any>;
switchMap(x => from([1, 2, 3]).pipe
浏览 21提问于2019-05-27得票数 1
回答已采纳
4回答
我有一个可以观察到的，应该每X秒完成一次动作。X的值动态变化。我一直在思考如何在运行时改变这个间隔。据我所知，我思想上的一个重大突破是，可观测值一旦被定义就不能改变，因此试图用新的间隔值重新定义观测值似乎不是正确的方法。我一直在尝试使用位于的代码至少，这个世界肯定需要更多的RxJ示例！
浏览 5提问于2017-02-07得票数 15
回答已采纳
我正在学习Rxjs，并想自己尝试几个例子，但我似乎无法使自己的头脑清醒地思考。<div class = "space"> .map((ev
浏览 4提问于2017-05-04得票数 2
回答已采纳
2回答
我想找出我需要的菜谱，但哪儿也找不到。const DataStream = stream("data"); /* observable of data */
DataStream的长长的管道操作人员名单下的引擎盖，只有一次，而不是每一个人参加。编辑:在内
浏览 3提问于2020-08-23得票数 2
回答已采纳
2回答
我正在为RXJS的拖放行为而挣扎。我想开始拖动一个元素后，250 on鼠标下来，为不劫持，单击事件的元素。let mouseUpStream = Rx.Observ
浏览 3提问于2017-04-12得票数 1
回答已采纳
2回答
我使用RxJS事件流和fetch API发出两个连续的HTTP请求，其中第一个请求的结果必须传递给第二个请求。("#xhr-rxjs");const xhr$ = of(xhrUrlBase在我上面有switchMap的地方，flatMap也会工作(返回一个值)，而map，
浏览 1提问于2019-12-16得票数 2
我正在用我的骨干项目来尝试RxJS。如何使用Rx.Observable.fromEvent/Rx.Observable.fromEventPattern来绑定这些事件，当视图消失时，这些事件也会解除绑定。说，RxJS支持将钩子连接到主干中，但无法找到方法。{}).distinctUntilChanged();
var respStream = keyStream.switchMapq=
浏览 7提问于2017-02-16得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
