В RXJS, как я могу сделать новое наблюдаемое ожидание еще одного наблюдаемого, прежде чем он продолжится? ⇐ Javascript

[Anonymous]

Короче говоря, у меня есть проблема с асинхронностью с системой авторизации.
Я использую Rxjs для выполнения этих операций с наблюдаемыми. Любая из этих операций должна ждать, что в настоящее время нет одного из уже запущенных, и если это дело, которое они должны ждать в упорядоченной очереди. Это два запроса, выполненные один за другим. Как сделать переменную для написания данных, которые записываются данные, и подождать, пока она закончится, прежде чем продолжить? < /P>
Я точно знаю, что мне здесь нужно! Очередь! Каждый запрос должен быть сложен и подождать предыдущего, чтобы завершить, прежде чем он продолжится. Как сделать это в RXJS? Как сделать наблюдаемое происхождение в очереди и подождать еще одну наблюдаемую, чтобы закончить?// this calls after signUpWithEmail and before writeDbData.
function onSignInEvent(userId): void {
readDbData(userId).subscribe(); // access to db but signUp hasn't finished yet so gets nothing.
}

function signUp(email, password): Observable {

return from(signUpWithEmail(email, password)).pipe(
// here credentials registered and event should trigger.
map(userId => createAccountData(userId)),
switchMap(account => writeDbData(account)) // here is saved in db.
);
}


Подробнее здесь: https://stackoverflow.com/questions/796 ... -it-contin