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



我想创建一个可变长度的输入事件窗口/缓冲区,该窗口/缓冲区在接收其他事件时会延长。

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

我想到的逻辑是缓冲击键,从第一个键向下开始,直到键向上 + 1 秒延迟。因此,如果用户仍在打字(即以 <1 秒的频率敲击键盘),我们将不会调用后端服务。 但是,一旦他们停止键入 1 秒钟,就会发出呼叫。

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

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

在 Rxjs 中,您将在此处找到一个很棒的教程:

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

在 Rx.Net 中,您将在此处找到一个有趣的示例:

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

希望这有帮助。

最新更新