拍摄下推动价值和等待 - 无扩展

Question

我有一个可观察的“热”的有效载荷：

IObservable<Payload> Payloads; 

我有一个设置功能，我现在需要抓住有效载荷，看到的是正在传递什么数据通过，然后继续进行安装。

从概念上讲，我想要做的是这样的：

Payload payload = await Payloads.First() 

即在该行的代码，我想等到一个有效载荷可再进行。

我可以使用Reactive Extensions中的任何功能吗？

Answer 1

您可以执行：

await Payloads.Take(1); 

或：

await Payloads.FirstAsync();