Как вернуть данные или сделать еще два запроса в Rx.js в зависимости от результата первого запроса?

Question

[Pantene742]

Мне нужно сделать запрос через HttpClient (Angular) После того как придет ответ нужно вернуть данные если емаил не существует в базе, а если существует то перевести поток на еще два запроса и вернуть в калбек субскрайба уже обработаный результат этих двух запросов(Observables так как httpClient юзаю).

Answer 1

[Demian Smith]

Это делается через switchMap:

this.httpClient.get('/check-email').pipe(
  switchMap(emailResult => {
    if (emailResult !== exists) {
      return of(dataForNonExistingEmail);
    }
    
    return forkJoin(
      this.httpClient.get('/user-data1'),
      this.httpClient.get('/user-data2')
    );
  })
)

Comments

[Pantene742]

Дружище ты самый лучший !!!! Благодарю

[Pantene742]

Я это все дело еще в combineLatest обернул так как массив имейлов имеется:
Вот как проинтерпритировал твой ответ.

return combineLatest(emails.map((email) => {
            return this.getUserByEmail(email).pipe(
              switchMap( (user: any) => {
                  if (user.exist && user.id) {
                      return of(user);
                  } else {
                      return forkJoin(
                          this.createIdentity(email),
                          this.createEnergy(email)
                      );
                  }
              }),
              map((user: any) => {
                  if (user.exist && user.id) {
                      return { ...user, email: user.email };
                  } else {
                      return { identity: user[0], energy: user[1] };
                  }
              })
          );
          }));

[Pantene742]

Также вот ссылочка с примером на стакблитз. https://stackblitz.com/edit/rxjs-renslp