c# - 如何阻塞直到 RX 流中发生事件？

Question

使用 Microsoft Reavtive Extensions (RX)，我想知道是否可以阻止直到事件发生？

像这样的事情:

observableStream.BlockUntilTrue(o => o.MyProperty == true);

我尝试过的

我已尝试observableStream.TakeUntil(o => o.MyProperty == true);，但这会立即退出。

Answer 1

阅读您的评论后，我重写了我的答案。在您的情况下，您可以使用 First但它将 RX 的异步性质改变为阻塞的同步代码。我想这就是你的问题。

var firstValue = observableStream.
  .Where(o => o.MyProperty)
  .First();

对 First 的调用将阻塞并等待可观察序列中的第一个值到达，这似乎就是您想要的。