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-react-enhancer): tiny improvements

Browse Source
This commit is contained in:
Josep M Sobrepere 2020-09-03 22:32:01 +02:00
parent 60a0fbda1e
commit 9e6b48acc3
1 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
packages/core/src/internal/react-enhancer.ts
View File

@ -50,7 +50,6 @@ const reactEnhancer = <T>(source$: Observable<T>): BehaviorObservable<T> => {
let promise: any
let error = EMPTY_VALUE
let valueResult: { type: "v"; payload: any } | undefined
const getValue = () => {
let timeoutToken
if (error !== EMPTY_VALUE) {
@ -62,10 +61,10 @@ const reactEnhancer = <T>(source$: Observable<T>): BehaviorObservable<T> => {
}
try {
const latest = (source$ as BehaviorObservable<T>).getValue()
return valueResult && Object.is(valueResult.payload, latest)
? valueResult
: (valueResult = { type: "v", payload: latest })
return {
type: "v",
payload: (source$ as BehaviorObservable<T>).getValue(),
}
} catch (e) {
if (promise) return promise
@ -74,11 +73,11 @@ const reactEnhancer = <T>(source$: Observable<T>): BehaviorObservable<T> => {
type: "s",
payload: result
.pipe(
filter((value) => value !== (SUSPENSE as any)),
filter((x) => x !== (SUSPENSE as any)),
take(1),
tap({
next(v) {
value = v
value = { type: "v", payload: v }
},
error(e) {
error = { type: "e", payload: e }
@ -92,12 +91,11 @@ const reactEnhancer = <T>(source$: Observable<T>): BehaviorObservable<T> => {
.catch(() => {})
.finally(() => {
promise = undefined
valueResult = undefined
}),
}
if (value !== EMPTY_VALUE) {
return (valueResult = { type: "v", payload: value })
return value
}
if (error !== EMPTY_VALUE) {