Как я могу «ждать» на наблюдаемом Rx?

Question

Я хотел бы быть в состоянии ждать на наблюдаемом, например,

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

наивной попытка приводит в AWAIT разрешающих сразу и не блокирует выполнение

Edit: псевдокода для моего полного предполагаемого USECASE является:

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

Я понимаю, что я могу переместить другой код в другую отдельную функцию и передать ее в обратный вызов подписки, но я надеюсь, что удастся этого избежать.

Answer 1

Вы должны сдать обещание await. Преобразуйте следующее событие наблюдаемого в обещание и ожидайте этого.

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

Редактировать примечание: Этот ответ первоначально использовался .Снять (1), но было изменено, чтобы использовать .first(), который позволяет избежать проблем обещания никогда не разрешение, если поток завершается до того, как значение проступает.

Answer 2

Вам нужно будет await обещание, поэтому вы захотите использовать toPromise(). См. this для получения дополнительной информации о toPromise().

Answer 3

Он должен быть

await observable.first().toPromise(); 

Как было отмечено в комментариях прежде, есть существенная разница между take(1) и first() операторов, когда существует пустой завершено наблюдаемым.

Observable.empty().first().toPromise() приведет к отклонению с помощью EmptyError, который может обрабатываться соответствующим образом, что обычно является желательным поведением.

И Observable.empty().take(1).toPromise() приведет к ожидающему обещания, что желательно ... почти никогда.