Was ist die while() Ersetzung in Rxjs 5?

Question

Von here sollte es eine while() Funktion geben, die die beobachtbare Basis unter Bedingung wiederholen, jedoch aus dem neuesten RXJS-Quellcode, wurde es offenbar diese while() Funktion entfernt. Also, was ist der Ersatz?

Answer 1

Sie wollen repeatWhen, aus der Dokumentation:

eine beobachtbare zurück, der die Quelle beobachtbare mit Ausnahme eines kompletten Spiegel. Wenn die Observable-Quellenaufrufe abgeschlossen sind, wird diese Methode an das vom Notifier zurückgegebene Observable ausgegeben. Wenn dieser Observable-Aufruf "Complete" oder "Fehler" aufruft, ruft diese Methode "Complete" oder "Error" in der untergeordneten Subskription auf. Andernfalls wird diese Methode die Quelle Observable erneut abonnieren.

Verwendung für so etwas wie while würde wie folgt sein:

// Continues to resubscribe so long as the condition function returns true. 
source.repeatWhen(
    notifiers => notifiers.takeWhile(_ => condition()) 
); 

Hinweis: Die reactivex.io/rxjs Seite hat einen Entscheidungsbaum-Widget, das bei der Suche nach einem Operator äußerst hilfreich ist an Ihren Bedürfnisse anzupassen .