RX语法等待，直到接收到特定值，接受该值，然后退订

Question

我正在等待流中的特定值，此时，我想在订阅者中执行一些工作，并从正在进行的流中取消订阅。最好的语法是什么?

Answer 1

像这样:

var value = stream.Where(/* predicate to select value of interest */)
                  .Take(1)
                  .Subscribe(value => /* do work */);