c# – FirstAsync如何工作？

在我不断追求吸吮的过程中,我试图理解Rx.net的FirstAsync()语法.大多数文档都是针对已弃用的First()
如果我理解正确,它允许我在流中的第一个元素到达时立即启动流.

假设我有一个流myStream,我想启动一个获取第一个元素的流,并根据该元素启动一个流.就我而言,它将是一个流.
我希望它能做到这一点：

— 1-2->
— A —>

我该怎么做？

myStream.FirstAsync().Return(() => return "A"); // doesn't compile

解决方法

我不知道为什么其他两个答案都在说.FirstAsync()返回一个Task(或者你应该调用.Result).它不返回任务,它返回IObservable< TSource>.可观测量是可以接受的,但它们不是任务.

要实现所需的功能,请执行以下操作：myStream.FirstAsync().选择(_ =>“A”).

你也可以做myStream.Take(1).选择(_ =>“A”).这与FirstAsync版本之间的区别在于,如果myStream在没有任何元素的情况下完成,则FirstAsync版本将抛出异常. Take(1)将完成,没有错误.