hazza/dspace-angular
1
0
Fork 1
mirror of https://github.com/DSpace/dspace-angular.git synced 2025-10-16 06:23:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

Intermediate commit

Browse Source
This commit is contained in:
Giuseppe Digilio
2019-03-11 20:07:11 +01:00
parent 11e77086ae
commit 013d464294
50 changed files with 181 additions and 167 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/app/core/tasks/tasks.service.ts
View File

@@ -9,12 +9,11 @@ import { isNotEmpty } from '../../shared/empty.util';
import { HttpOptions } from '../dspace-rest-v2/dspace-rest-v2.service';
import { ProcessTaskResponse } from './models/process-task-response';
import { RemoteDataError } from '../data/remote-data-error';
import { NormalizedObject } from '../cache/models/normalized-object.model';
import { getResponseFromEntry } from '../shared/operators';
import { ErrorResponse, MessageResponse, RestResponse } from '../cache/response.models';
import { CacheableObject } from '../cache/object-cache.reducer';
export abstract class TasksService<TNormalized extends NormalizedObject, TDomain extends CacheableObject> extends DataService<TNormalized, TDomain> {
export abstract class TasksService<T extends CacheableObject> extends DataService<T> {
public getBrowseEndpoint(options: FindAllOptions): Observable<string> {
return this.halService.getEndpoint(this.linkPath);
@@ -34,7 +33,7 @@ export abstract class TasksService<TNormalized extends NormalizedObject, TDomain
));
const successResponses = responses.pipe(
filter((response: RestResponse) => response.isSuccessful),
map((response: MessageResponse) => new ProcessTaskResponse(response.isSuccessful)),
map((response: MessageResponse) => new ProcessTaskResponse(response.isSuccessful)),
distinctUntilChanged()
);
return observableMerge(errorResponses, successResponses);