如何从 ReplaySubject获取最新值完成之前

Question

我需要一种方法来获取添加到 ReplaySubject 中符合特定条件的最新项目。下面的示例代码做了我需要它做的事情，但感觉不是正确的方法：

static void Main(string[] args)
{
    var o = new ReplaySubject<string>();

    o.OnNext("blueberry");
    o.OnNext("chimpanzee");
    o.OnNext("abacus");
    o.OnNext("banana");
    o.OnNext("apple");
    o.OnNext("cheese");

    var latest = o.Where(i => i.StartsWith("b"))
        .Latest().First();

    Console.WriteLine(latest);

    Console.WriteLine("Press any key to exit");
    Console.ReadKey();
}

输出：

banana
Press any key to exit

最初，我尝试使用 .Where().TakeLast(1);但是，我现在从之前的问题中知道您必须在 TakeLast() 返回任何内容之前对主题调用 OnComplete()。调用 OnComplete() 对我来说不是一个选择，因为我需要保持此流打开。

谁能验证这是否是实现我想要实现的目标的最有效方法？谢谢！

编辑

请注意，我正在使用反应式扩展，并且 IEnumerable 代码示例将不起作用。

更新

我倾向于以下代码，因为我相信它是非阻塞的，除非有人能以不同的方式告诉我：

var latest = o.Where(i => i.StartsWith("b")).Replay(1);

using (latest.Connect())
     latest.Subscribe(Console.WriteLine);

Answer 1

您可以考虑使用BehaviorSubject。缺点是您必须在一开始就订阅，但这可能正是您想要做的。这应该为您提供所需的隔离。

var o = new ReplaySubject<string>();
var bs = new BehaviorSubject<string>(default(string));
o.Where(i => i.StartsWith("b")).Subscribe(bs);

o.OnNext("blueberry"); Console.WriteLine(bs.First());
o.OnNext("chimpanzee"); Console.WriteLine(bs.First());
o.OnNext("abacus"); Console.WriteLine(bs.First());
o.OnNext("banana"); Console.WriteLine(bs.First());
o.OnNext("apple"); Console.WriteLine(bs.First());
o.OnNext("cheese"); Console.WriteLine(bs.First());

输出：

blueberry
blueberry
blueberry
banana
banana
banana

Answer 2

只要您乐意使用这些阻塞运算符（看起来您就是这样），我就会考虑使用 MostRecent 运算符。

static void Main(string[] args)
{
    var o = new ReplaySubject<string>();

    o.OnNext("blueberry");
    o.OnNext("chimpanzee");
    o.OnNext("abacus");
    o.OnNext("banana");
    o.OnNext("apple");
    o.OnNext("cheese");

    var latest = o.Where(i => i.StartsWith("b"))
        .MostRecent("SomeDefaultValue")
        .First();

    Console.WriteLine(latest);

    Console.WriteLine("Press any key to exit");
    Console.ReadKey();
}