Rx - etkinlikten çıkmak için

Question

Bir INotifyPropertyChanged nesnesine Foo'yum. Ben Rx en FromEvent yöntemini kullanarak olayların gözlemlenebilir akışı içine Foo çevirmek:

var myFoo = new Foo(); 
var eventStream = Observable.FromEvent<PropertyChangedEventArgs>(myFoo, "PropertyChanged"); 

Şimdi belirli bir özellik değişti dinlemek istiyor ve .adresine yapabilirsiniz == 100 ise, abonelikten:

eventStream 
    .Where(e => myFoo.Progress == 100) 
    .Subscribe(OnFooFinished); 

nasıl İlerleme == 100 iken aboneliği iptal edebilir miyim? .Where maddesinden sonra bir .Take (1) çağrısı eklerseniz, bu otomatik olarak aboneliği iptal eder mi?

Answer 1

Bir seçenek Subscribe döndürülen değerini kullanmaktır:

IDisposable subscription = eventStream.Where(e => myFoo.Progress == 100) 
             .Subscribe(OnFooFinished); 

... 

// Unsubscribe 
subscription.Dispose(); 

Ben şüpheliTake(1) kullanarak aslında olsa abonelikten edeceğini ve bu sizin için kıvrımlara olabilir. Buna biraz baktığımda, bu otomatik olarak aboneliği iptal eden "tamamlandı" mesajını vereceğinden, bu 'un aboneliğinden çıkacağından eminim. Ben

Answer 2

Sen TakeWhile yöntemi kullanabilirsiniz :(korkuyorum şu anda kesin bu kontrol etmek için zaman yok:

eventStream.TakeWhile(e => myFoo.Progress != 100); 

TakeWhile yatan gözlemlenebilir dizisi imha edecek onun yüklem Eğer elle imha aramak zorunda değil olacak, false döndürür aşağıda Jon'un cevabını kabul ettik