Demian Smith

Как только вы попали в callback error функции subscribe - это означает что поезд ушел и прийдётся что-то мудрить чтоб переподписаться на

fromEvent<any>(this.sendBtn.nativeElement, 'click')

Каких-то магических операторов для того чтоб и в функцию error попасть и подписку при этом сохранить не существует. Можно, конечно, сделать как-то так:

import { EMPTY } from 'rxjs';

fromEvent<any>(this.sendBtn.nativeElement, 'click')
  .pipe(
    map((event) => event.target.value),
    tap(() => this.documentSend$.next(true)),
    switchMap(() =>
      this.applicationDocumentsService
        .sendrequest({
          appid: this.appid,
          req: this.requestDocument,
        })
        .pipe(
          cachError((error: HttpErrorResponse) => {
            this.messageService.showMessage('', `${err.error}`, 'error');
            return EMPTY;
          }),
          finalize(() => this.documentSend$.next(false)),
        )
    ),

    takeUntil(this.closed$)
  )
  .subscribe((response) => {
    console.log(response);
    this.dialogRef.close(response);
  });

Это делается через 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')
    );
  })
)

Как-то так:

this.httpClient.request(...).pipe(
  repeatWhen(complete => complete.pipe(delay(20000))
).subscribe(result => console.log(result))

// Да, сначала мы делаем map, потому что он делается полюбому:

let doSomething$ = this.myApi.getSomething(id).pipe(
  map(tags => ({ ...updatedShop, tags }))
)

// А затем мы делаем mergeMap если понадобится:

if (shop.isNew) {
  doSomething$ = doSomething$.pipe(
    mergeMap(() =>
                  this.myApi.addTags(updatedShop.id, shop.tags).pipe(
                      map(() => {
                          return {
                              ...updatedShop,
                              tags: shop.tags
                          };
                      })
                  )
              )
  )
}

// ну и затем подписываемся на это дело чтоб оно начало работать:

doSomething$.subscribe();

Вам будет значительно легче понять RxJS после просмотра вот этого видео: https://www.youtube.com/watch?v=3LKMwkuK0ZE Оно слега отстало от времени (операторы к обозревателю теперь добавляются через функцию pipe()), но сами принципы, описанные в видео, никуда не делись.

UPD

Если код выше повергает вас в тоску, то можно сделать так:

this.myApi.getSomething(id).pipe(
  map(tags => ({ ...updatedShop, tags })),
  mergeMap((tags) => {
    if (!shop.isNew) {
      return of(tags);
    }
   return this.myApi.addTags(updatedShop.id, shop.tags).pipe(
                      map(() => {
                          return {
                              ...updatedShop,
                              tags: shop.tags
                          };
                      })
                  )
  }),
)

Имеется ввиду, что можно иф вынести в сам mergeMap. И если магаз не новый, то возвращать обзёрвбл от магаза, а если новый, то сделать что-то там еще.