Wie kann ich auf einem Rx Observable "erwarten"?

Question

Ich würde gerne auf eine beobachtbare, z.B.

const source = Rx.Observable.create(/* ... */) 
//... 
await source; 

Ein naiver Versuch ergibt die await sofort lösen und nicht die Ausführung blockiert

Edit: Der Pseudo-Code für meine volle beabsichtigte usecase ist:

if (condition) { 
    await observable; 
} 
// a bunch of other code 

Ich verstehe, dass ich die bewegen kann anderen Code in eine andere separate Funktion und übergeben Sie es in den Rückruf abonnieren, aber ich hoffe, in der Lage, das zu vermeiden.

Answer 1

Sie müssen ein Versprechen an await übergeben. Wandeln Sie das nächste Event des Observablen in ein Versprechen um und erwarten Sie es.

if (condition) { 
    await observable.first().toPromise(); 
} 

bearbeitet Hinweis: Diese Antwort ursprünglich .take (1), wurde aber geändert verwenden .First(), die das Problem der Verheißung vermeidet nie lösen, wenn der Strom endet, bevor ein Wert kommt durch.

Answer 2

Sie müssen await ein Versprechen, so dass Sie toPromise() verwenden möchten. Weitere Informationen zu toPromise() finden Sie unter this.

Answer 3

Es hat

await observable.first().toPromise(); 

sein, wie es vorher in den Kommentaren darauf hingewiesen wurde, gibt es erhebliche Unterschiede zwischen take(1) und first() Operatoren, wenn es leer abgeschlossen zu beobachten ist.

Observable.empty().first().toPromise() führt zu einer Ablehnung mit EmptyError, die entsprechend behandelt werden kann, was im Allgemeinen ein wünschenswertes Verhalten ist.

Und Observable.empty().take(1).toPromise() wird ausstehende Versprechen ergeben, was wünschenswert ist ... fast nie.