在我不断追求吸吮的过程中,我试图理解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)将完成,没有错误.
