DT
Size: a a a
DT
S
DT
S
S
S
DT
updateEntity<T>(entity: Partial<T>): Observable<T> {
const destroy$ = new Subject();
return {request$: new Observable(observer => {
this.http.patch<T>(ENTITY_ROUTE, entity)
.pipe(handleHttpError(), takeUntil(destroy$))
.subscribe(
result => { observer.next(result); observer.complete() },
error => { observer.error(error); observer.complete() },
() => { observer.complete() },
);
}),
cancel: () => { destroy$.next(); destroy.complete(); },
}
...
const {request$, cancel} = service.updateEntity<A>(entity);
request$.pipe(takeUntilDestroyed(this)).subscribe(...)
setTimeout(() => cancel(), 100)
DT
S
DT
S
D
D
nt
D
nt
nt
D