Wie kann ich eine Observable abbestellen?

Question

Wenn ich etwas, das wie folgt aussieht:

func foo() -> Observable<Foo> { 
    return Observable.create { observer in 
     // ... 
    } 
    } 

    func bar() { 
    foo().observeOn(MainScheduler.instance) 
     .subscribeNext { 
     // ... 
     } 
     .addDisposableTo(disposeBag) 
    } 

Wenn ich in bar später zu unsubscribe aus dem beobachtbaren will, wie würde ich das tun?

aktualisieren

Ich bin mir bewusst, ich dispose nennen kann, sondern nach dem RxSwift docs:

Beachten Sie, dass Sie in der Regel nicht wollen, manuell entsorgen nennen; Dies ist nur ein Bildungsbeispiel. Der manuelle Aufruf von dispose ist normalerweise ein schlechter Code-Geruch.

So ist unsubscribe gerade nicht implementiert? Ich bin durch den RxSwift-Code spelunking gegangen, und in dem Ausmaß, dass ich verstehen kann, was los ist, sieht es nicht aus wie die , die von den Subscribe-Methoden zurückgegeben wird, ist alles mit nützlichen Funktionen (außer Entsorgung).

Answer 1

Sie fügen die Observable, die von foo zurückgegeben wird, zu disposeBag hinzu. Es entsorgt das Abonnement, wenn es freigegeben wird. Sie können "manuell" die disposeBag Freigabe durch

disposeBag = nil

irgendwo in der Klasse aufrufen.

Nach dem Bearbeiten der Frage: Sie möchten einige Observables selektiv abbestellen, wahrscheinlich wenn einige Bedingungen erfüllt sind. Sie können einen anderen Observable verwenden, der diese Bedingungen darstellt, und den Operator takeUntil verwenden, um das Abonnement nach Bedarf abzubrechen.

//given that cancellingObservable sends `next` value when the subscription to `foo` is no longer needed 

foo().observeOn(MainScheduler.instance) 
    .takeUntil(cancellingObservable) 
    .subscribeNext { 
    // ... 
    } 
    .addDisposableTo(disposeBag) 

Answer 2

Was ich tat, war die Schaffung einer anderen DisposeBag

var tempBag = DisposeBag() 

fun bar() { 
    foo().subscribe().addDisposable(tempBag) 
} 

so, wenn Sie entsorgen möchten, können Sie einfach tun tempBag = nil wenn Sie freigeben möchten. während Sie noch ein anderes DisposeBag haben, das andere Wegwerfartikel am Leben erhält.