有没有办法监听 Reactive Extensions 中没有引发任何事件？

Question

我有要求在用户开始输入时关闭某个功能，这很简单。当用户停止输入时，我想重新打开该功能。

如果没有响应式扩展，可以简单地使用timer 实现此功能，该功能将每次最后一次击键 时的计时器重置为1 second，并且当user stops typing and timer elapses 开启功能时重新开始。

我可以调用任何方法来达到与Reactive Extensions相同的效果吗？

Throttle 或Timeout 每隔1 second 就会不断调用订阅者/异常操作

更新

XAML

<RichTextBox MaxHeight="1000" VerticalScrollBarVisibility="Visible" x:Name="meh"/>

扩展类

public static IObservable<EventArgs> ObserveTextChanged(this RichTextBox rtb)
{
 return Observable.FromEventPattern<TextChangedEventHandler, EventArgs>(
            h => rtb.TextChanged += h,
            h => rtb.TextChanged -= h)
                         .Select(ep => ep.EventArgs);
}

类，其中meh 是RichTextBox

public class MainWindow()
{
 //Change this to be the keypress/propertychagned event. The type T doesn't matter we ignore it
 var typing = meh.ObserveTextChanged().Take(4);
 var silence = meh.ObserveTextChanged().IgnoreElements();
 var source = typing.Concat(silence).Concat(typing);
 var disableSpellcheck = source.Select(_ => false);
 var enableSpellcheck = source.Select(_ => Observable.Timer(TimeSpan.FromSeconds(1)))
                                     .Switch()
                                     .Select(_ => true);

 disableSpellcheck.Merge(enableSpellcheck)
                  .DistinctUntilChanged()
                  .Subscribe(SetFlag);

 }

// Define other methods and classes here
public void SetFlag(bool flag)
{
 Dispatcher.Invoke(new Action(() => SpellCheck.SetIsEnabled(meh, flag)));
 Debug.Write("flag");
}

Answer 1

这里是显示如何将上述代码移植到 WPF 的所有代码。看来这里的沟通有差距，所以我创建了整个 wpf 应用来证明这一点。

<Window x:Class="StackoverFlow_23764884.MainWindow"
        xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation"
        xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml"
        Title="MainWindow" Height="350" Width="525">
    <StackPanel>
        <HeaderedContentControl Header="When checked, spellcheck is enabled (emulated)">
            <CheckBox x:Name="spellChecking" IsChecked="True" IsEnabled="False"/>
        </HeaderedContentControl>

        <HeaderedContentControl Header="Type here to see the Spellcheck enable and disable">
            <RichTextBox x:Name="meh" Width="400" Height="300" />
        </HeaderedContentControl>
    </StackPanel>
</Window>

以及背后的代码：

using System;
using System.Reactive.Linq;
using System.Windows;
using System.Windows.Controls;

namespace StackoverFlow_23764884
{
    /// <summary>
    /// Interaction logic for MainWindow.xaml
    /// </summary>
    public partial class MainWindow : Window
    {
        public MainWindow()
        {
            InitializeComponent();

            var source = meh.ObserveTextChanged();
            var disableSpellcheck = source.Select(_ => false);
            var enableSpellcheck = source.Select(_ => Observable.Timer(TimeSpan.FromSeconds(1)))
                                         .Switch()
                                         .Select(_ => true);

            disableSpellcheck.Merge(enableSpellcheck)
                             .DistinctUntilChanged()
                             .ObserveOnDispatcher()
                             .Subscribe(isEnabled => spellChecking.IsChecked=isEnabled);
        }

    }

    public static class ObEx
    {
        public static IObservable<EventArgs> ObserveTextChanged(this RichTextBox rtb)
        {
            return Observable.FromEventPattern<TextChangedEventHandler, EventArgs>(
                h => rtb.TextChanged += h,
                h => rtb.TextChanged -= h)
                .Select(ep => ep.EventArgs);
        }
    }
}

我在 Rx-WPF nuget 包中提取了代码所需的所有其他内容。这是 .NET 4.5。

这是一个展示如何解决问题的示例。即我不建议使用.ObserveOnDispatcher()，我不建议编写代码隐藏，而且我知道在复选框上设置 IsEnabled 并不是实际上进行拼写检查。我希望这足以让观众重新创建他们的实际解决方案。

我确实希望它有所帮助。

Answer 2

好问题。

可能有很多方法可以解决这个问题，但这里有一个您可以使用的方法。首先，我们需要源可观察序列。这可能是一个按键事件或属性更改事件，已使用 FromEvent 或其他一些工厂/转换或 ReactiveUI 转换为 Observable 序列。

在这个示例中，我将使用Observable.Interval(TimeSpan.FromSeconds(0.25)).Take(4); 作为源序列的替代品（只是为了证明这个概念）。

接下来，我们需要决定何时需要禁用该功能（拼写检查？）。这是源序列产生值的时候。

var disableSpellcheck = source.Select(_=>false);

然后我们需要决定何时需要重新启用该功能。这是在源序列上出现 1 秒的静默时间。实现这一点的一个技巧是为源中的每个事件创建一个一秒计时器。创建新的 Timer 时，取消之前的 Timer。你可以通过创建一个嵌套的 observable 序列来做到这一点，并在它产生一个新的序列时使用 Switch 取消之前的内部序列。

var enableSpellcheck = source.Select(_=>Observable.Timer(TimeSpan.FromSeconds(1)))
      .Switch()
      .Select(_=>true);

现在我们要合并这两个序列，并将结果推送到启用/禁用该功能的方法。

Observable.Merge(disableSpellcheck, enableSpellcheck)
          .Subscribe(isEnabled=>SetFlag(isEnabled));

但是，如上所述，每次源序列产生一个值时都会调用 SetFlag(false)。这可以通过使用DistinctUntilChanged() 运算符轻松解决。

最终的示例（LinqPad）代码如下：

void Main()
{
    //Change this to be the keypress/propertychagned event. The type T doesn't matter we ignore it
    var typing = Observable.Interval(TimeSpan.FromSeconds(0.25)).Take(4);
var silence = Observable.Timer(TimeSpan.FromSeconds(1)).IgnoreElements();
var source = typing.Concat(silence).Concat(typing);

    var disableSpellcheck = source.Select(_=>false);
    var enableSpellcheck = source.Select(_=>Observable.Timer(TimeSpan.FromSeconds(1)))
        .Switch()
        .Select(_=>true);

    Observable.Merge(disableSpellcheck, enableSpellcheck)
            .DistinctUntilChanged()
            .Subscribe(isEnabled=>SetFlag(isEnabled));

}

// Define other methods and classes here
public void SetFlag(bool flag)
{
    flag.Dump("flag");
}

Answer 3

我相信this example 和Throttle 可以解决类似的问题。

所以类似的东西也可能对你有用：

var throttled = observable.Throttle(TimeSpan.FromMilliseconds(1000));
using (throttled.Subscribe(x => RestoreThing())) {}

Answer 4

我不是 RX 大师，但我创建了一个似乎可以工作的示例 WinForms 应用程序。在表格上，我有textBox1 和button1 就是这样。

这是代码隐藏：

public Form1()
        {
            InitializeComponent();

            var observable = Observable.FromEventPattern(
                s => textBox1.TextChanged += s, s => textBox1.TextChanged -= s)
                //make sure we are on the UI thread
                .ObserveOn(SynchronizationContext.Current)
                //immediately set it to false
                .Do(_ => UpdateEnabledStatus(false))
                //throttle for one second
                .Throttle(TimeSpan.FromMilliseconds(1000))
                //again, make sure on UI thread
                .ObserveOn(SynchronizationContext.Current)
                //now re-enable
                .Subscribe(_ => UpdateEnabledStatus(true));
        }

        private void UpdateEnabledStatus(bool enabled)
        {
            button1.Enabled = enabled;
        }

这可以按您的意愿工作，并且不会每秒都使用UpdateEnabledStatus 方法，至少在我的测试中是这样。