From df8fdaaad178fecb31ed132e05725bfef6aa03f7 Mon Sep 17 00:00:00 2001 From: Josep M Sobrepere Date: Mon, 27 Jul 2020 22:12:32 +0200 Subject: [PATCH] chore(core): simplify internal share-latest --- packages/core/src/internal/share-latest.ts | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/packages/core/src/internal/share-latest.ts b/packages/core/src/internal/share-latest.ts index a2836a6..afed2a3 100644 --- a/packages/core/src/internal/share-latest.ts +++ b/packages/core/src/internal/share-latest.ts @@ -14,21 +14,21 @@ const shareLatest = ( let refCount = 0 let currentValue: T = EMPTY_VALUE - const result = new Observable(subscriber => { + const result = new Observable((subscriber) => { refCount++ let innerSub: Subscription if (!subject) { subject = new Subject() innerSub = subject.subscribe(subscriber) subscription = source$.subscribe( - value => { + (value) => { subject!.next((currentValue = value)) }, - err => { - const subjectError = subject!.error.bind(subject) + (err) => { + const _subject = subject subscription = undefined subject = undefined - subjectError(err) + _subject!.error(err) }, () => { subscription = undefined