import { MatPaginator } from "@angular/material/paginator";
import { Sort } from "@angular/material/sort";
import { MatTableDataSource } from "@angular/material/table";
-import { EMPTY, forkJoin, of, pipe, Subscription, concat, Observable } from "rxjs";
+import { EMPTY, forkJoin, of, Subscription, concat } from "rxjs";
import { BehaviorSubject } from "rxjs/BehaviorSubject";
import { mergeMap, finalize, map, tap, concatMap, delay, skip, catchError } from "rxjs/operators";
import { ConsumerService } from "@services/ei/consumer.service";
dataSubscription(): Subscription {
const jobsInfo$ = this.consumerService.getJobIds().pipe(
+ catchError(_ => { return EMPTY }),
tap((_) => {
this.jobList = [] as Job[];
}),
intercept(request: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {
console.log('Interceptor Invoked' + request.url);
- if (!request.url.includes("info-jobs")) {
- return next.handle(request).pipe(
- catchError((error: HttpErrorResponse) => {
- console.error("Error from error interceptor", error);
-
+ return next.handle(request).pipe(
+ catchError((error: HttpErrorResponse) => {
+ console.error("Error from error interceptor", error);
+
+ if (!request.url.includes("info-jobs") && error.status != 404) {
// show dialog for error message
this.notificationService.error(error.message);
- return throwError(error);
- })
- ) as Observable<HttpEvent<any>>;
- } else {
- return next.handle(request).pipe(
- catchError((error: HttpErrorResponse) => {
- console.error("Error from error interceptor", error);
- return throwError(error);
- })
- ) as Observable<HttpEvent<any>>;
- }
+ }
+ return throwError(error);
+ })
+ ) as Observable<HttpEvent<any>>;
}
}