4

我正在试验 RX，并遇到以下问题（至少我认为这是一个问题）。下面的代码创建了一个 observable，并订阅了它两次。我认为订阅应该独立运行，所以下面的代码会在每次按键时输出两行，每个订阅对应一行。但情况并非如此，我总是只获得一个订阅来处理特定的击键，半随机的第一或第二。为什么会发生这种情况以及进行多个观察者的“推荐”方式是什么？

    static IEnumerable<ConsoleKeyInfo> KeyPresses()
    {
        for (; ; )
        {
            var currentKey = Console.ReadKey(true);

            if (currentKey.Key == ConsoleKey.Enter)
                yield break;
            yield return currentKey;
        }
    }

    static void Main()
    {
        var timeToStop = new ManualResetEvent(false);
        var keypresses = KeyPresses().ToObservable();
        keypresses.Subscribe(key => Console.WriteLine(key.Key + "1"), 
           () => timeToStop.Set());
        keypresses.Subscribe(key => Console.WriteLine(key.Key + "2"), 
           () => timeToStop.Set());
        timeToStop.WaitOne();
    }
4

1 回答 1

2

这种特殊行为的原因是 observable 是冷的。这意味着每个订阅者都在使用 .GetNext() 上的 ReadKey 调用。一旦我通过调用“热身”观察到

var keypresses = KeyPresses().ToObservable().Publish();

每个订阅者都收到了自己的价值。

于 2010-01-24T20:20:31.570 回答