diff --git a/app/services/core/rx-entity-proxy.ts b/app/services/core/rx-entity-proxy.ts index 942af0407c..a408b76ed8 100644 --- a/app/services/core/rx-entity-proxy.ts +++ b/app/services/core/rx-entity-proxy.ts @@ -84,26 +84,20 @@ export abstract class RxEntityProxy extends RxProxyBase(getProxy: RxEntityProxy): Observable { const obs = new AsyncSubject(); - const errorCallback = (e) => { - sub.unsubscribe(); - obs.error(e); - obs.complete(); - }; - - const sub = getProxy.item.subscribe({ - next: (item: TEntity) => { - if (item) { - sub.unsubscribe(); - obs.next(item); - obs.complete(); - getProxy.dispose(); - } - }, - error: errorCallback, - }); - getProxy.fetch().subscribe({ - error: errorCallback, + next: () => { + getProxy.item.first().subscribe((item: TEntity) => { + if (item) { + obs.next(item); + obs.complete(); + getProxy.dispose(); + } + }); + }, + error: (e) => { + obs.error(e); + obs.complete(); + }, }); return obs.asObservable();