archive-gh-me/react-rxjs
1
0
Fork 0
mirror of https://github.com/re-rxjs/react-rxjs.git synced 2025-12-08 18:01:51 +00:00
Code Issues Projects Releases Wiki Activity

chore(core): simplify internal share-latest

Browse Source
This commit is contained in:
Josep M Sobrepere 2020-07-27 22:12:32 +02:00
parent dfcd6d8fec
commit df8fdaaad1
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
packages/core/src/internal/share-latest.ts
View File

@ -14,21 +14,21 @@ const shareLatest = <T>(
let refCount = 0
let currentValue: T = EMPTY_VALUE
const result = new Observable<T>(subscriber => {
const result = new Observable<T>((subscriber) => {
refCount++
let innerSub: Subscription
if (!subject) {
subject = new Subject<T>()
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