javascript - 响应式框架中的滑动窗口/缓冲区

标签 javascript system.reactive rxjs

我想创建一个可变长度的输入事件窗口/缓冲区,当它接收到额外的事件时会变长。

这是为了实现“键入时搜索”功能。我想捕获点击,但为了不给服务器造成压力,我想明智地进行服务调用。

我想到的逻辑是缓冲击键,从第一个键按下开始,直到一个键弹起 + 1 秒延迟。因此,如果用户仍在打字(即敲击键盘的频率小于 1 秒),我们将不会调用后台服务。然而,一旦他们停止打字 1 秒钟,就会调用电话。

最佳答案

我认为您正在寻找的是 Rx 的 Throttle 功能。

要在 C# 和 Javascript 中完成你想要的(问题被标记为 c# 和 rxjs,即使 javascript 确实是你需要的):

Rxjs ,您会在 here 中找到很棒的教程:

$(document).ready(function(){
    $('#myInput')
        .toObservable("keyup")
        .Select(function(){ return $('#myInput').val(); })
        .Throttle(500)
        .Subscribe(function(text){ console.log("fire up ajax call"); });
});

Rx.Net ,您会在 here 中找到一个有趣的示例:

SearchTextChangedObservable = Observable.FromEventPattern<TextChangedEventArgs>(this.textBox, "TextChanged");
_currentSubscription = SearchTextChangedObservable.Throttle(TimeSpan.FromSeconds(.5)).ObserveOnDispatcher().Subscribe(e => this.ListItems.Add(this.textBox.Text));

希望这对您有所帮助。

关于javascript - 响应式框架中的滑动窗口/缓冲区,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/19600790/

相关文章:

javascript - 我可以通过 Google Chrome 扩展程序以编程方式打开开发工具吗?

c# - IObservable .Cast<>() 和协方差

c# - C#Reactive Extensions(Rx)-如何合并流并存储状态变量以生成自定义输出

javascript - 在对话框中的第二次渲染中发布渲染谷歌地图

javascript - 预加载、延迟加载页面 Ionic 4

javascript - React 中条件渲染的转换问题

c# - IObservable.Create的subscribe参数返回的Action到底是干什么用的?

angular - 通知子组件哪个是事件的

angular - RxJS Observables 和构建过滤列表的正确方法

angular - RxJs Angular 7 HttpClient 多个 POST 与 forkJoin 删除第二个订阅?