Skip to content
Snippets Groups Projects
Commit a49f9bdb authored by Kristof De Langhe's avatar Kristof De Langhe
Browse files

54472: Intermediate commit

parent 0cf65b3f
No related branches found
No related tags found
No related merge requests found
import { distinctUntilChanged, filter, first, map, take } from 'rxjs/operators';
import { distinctUntilChanged, filter, first, map, switchMap, take } from 'rxjs/operators';
import { Observable } from 'rxjs';
import { Store } from '@ngrx/store';
import { hasValue, isNotEmpty, isNotEmptyOperator } from '../../shared/empty.util';
......@@ -13,7 +13,7 @@ import {
FindAllOptions,
FindAllRequest,
FindByIDRequest,
GetRequest
GetRequest, RestRequest
} from './request.models';
import { RequestService } from './request.service';
import { NormalizedObject } from '../cache/models/normalized-object.model';
......@@ -143,6 +143,8 @@ export abstract class DataService<TNormalized extends NormalizedObject, TDomain>
);
const selfLink$ = request$.pipe(
map((restRequest: RestRequest) => restRequest.href),
switchMap((href: string) => this.requestService.getByHref(href)),
getResponseFromEntry(),
map((response: RestResponse) => {
if (!response.isSuccessful && response instanceof ErrorResponse) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment