如何使用反应式扩展对事件流中匹配特定模式的内容做出反应？

Question

假设您想在文本框中的字符流中的某个单词与特定模式匹配时做出反应，可以使用 Rx 来完成吗？因此，如果初始源看起来像这样：

var charStream = Observable.
    FromEventPattern<KeyPressEventArgs>(textBox, "KeyPress");

要从中创建一个可观察的单词流，我想您可以订阅 charStream 并在看到单词分隔符时发布 OnNext ：

StringBuilder word = new StringBuilder();
var res = charStream.Subscribe(keyCharEv => {
    if (!Char.IsWordSeparator(keyCharEv.EventArgs.KeyChar))
        word.Append(keyCharEv.EventArgs.KeyChar);
    else
    {
        wordObservable.OnNext(word.ToString());
        word.Clear();
    }
});

然后，wordObservable 的观察者可以过滤掉与该模式匹配的单词。然而，上述内容可以通过.NET中的老式事件机制轻松完成，并且也没有考虑到某些文本可以复制到文本框中的任何位置，或者在中间按下回车键 ，

我的问题是，Rx 是否不适合这类问题，或者 Rx 中是否有一些东西可以应用在这里（我确实意识到除了使用 Rx 之外还有其他方法来解决这个问题 我只是想了解其运作原理这里的 Rx）？

Answer 1

我相信可以使用 反应式扩展 来完成，但我相信你'从错误的角度来处理问题。

您正在查看 KeyPress event作为获取字符流的方式。这是不正确的，KeyPress 事件的可观察结果就是按键。是的，它们有时对应于单词中的字符，但正如您提到的，有些按键与单词中的字符无关，而是其他操作。

也就是说，您不应该订阅 KeyPress 事件，而应该订阅 TextChanged 事件。然后，您的 IObservable应该返回与单词相对应的字符串实例数组。

换句话说，不是流式传输按键并尝试以附加方式找出框中的单词，而是获取框中的整个文本并更改框中的单词您观察到的事物：

var textChanges = Observable.
    FromEventPattern<EventHandler>(textBox, "TextChanged");

// Create an observable that contains the splits.
IObservable<IList<string>> observableWordChanges = textChanges.Select(e => { 
    // Get the text.
    string text = (e.Sender as TextBox).Text;

    // The current word.
    var word = new StringBuilder();

    // The list of words.
    IList<string> words = new List<string>();

    // Parse.
    foreach (char c in text)
    {
        if (!Char.IsWordSeparator(c))
            word.Append(c);
        else
        {
            // Add to the words.
            words.Add(word.ToString());

            // Clear the builder.
            word.Clear();
        }
    }

    // Return the words.
    return words;
});

从这里，您可以订阅单词作为集合的更改，而不仅仅是 TextBox 中的字符。

当然，它的计算量更大，但另一种选择是捕获任何按键所具有的所有不同状态，并且您可能无法获得所有正确的状态。

这样，您每次都会得到框中的单词，并可以与之前的单词进行正确比较。

至于与仅使用原始事件相比这样做是否有任何价值，我会说是的。使用响应式扩展的两个巨大好处是：

• 封装事件流处理逻辑。
• 处理对同一事件流的多个订阅。

在这个特定的示例中，您可以从两者中受益。

您可以通过挂钩 TextChanged 事件来完成单词集解析，但是您必须在与事件处理程序相同的结构中存储某种状态（在本例中，StringBuilder< /a>) 声明于。反应性扩展，这本来是不需要的（它包含在外壳中）。

此外，如果您想要将一些附加行为附加到事件流的处理中，则必须在一个事件处理程序或多个事件处理程序中进行两次调用。使用响应式扩展，由于状态封装得更好，可以更轻松地将事件流的多个处理程序添加到同一事件，无论您选择什么时间（取决于您订阅的时间）。

Answer 2

这对于 Rx 来说是一个很好的问题，正如其他人已经演示的那样。 Rx 提供的好处之一是事件处理逻辑与事件处理逻辑的组合和分离。

对于事件处理程序，这......很困难。但使用 Rx，您可以拥有一个 IObservableWords 可以

• 替换为用于测试的替代实现
• 由额外的过滤器和投影组成，独立于单词的来源
• 订阅，就像正常事件一样

Answer 3

如果我正确理解了您的问题，那么每当文本框值更改时，您都希望从文本框生成单词流。

这可以在 Rx 中轻松完成，使用：

Observable.FromEvent<EventArgs>(txt, "TextChanged")
    .Select(e => ((TextBox)e.Sender).Text)
    .SelectMany(t => t.Split(" ".ToCharArray()).Where(
        a => !String.IsNullOrWhiteSpace(a)))

然后您可以订阅上面的可观察对象，以对来自文本框的单词做出反应。

您可以在正常的事件处理中执行此操作，但当您需要组合多个事件流并执行过滤器、缓冲区等复杂处理时，Rx 的力量就会发挥作用。