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: improve useObservable implementation

Browse Source
This commit is contained in:
Josep M Sobrepere 2020-06-09 00:26:56 +02:00
parent e750dd13b8
commit ad1c39e19c
1 changed files with 1 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/useObservable.ts
View File

@ -20,16 +20,11 @@ const useObservable = <O, I>(
? undefined
: setTimeout(setState, suspenseTime, initialValue)
const stopInitialState = () => {
if (!timeoutToken) return
timeoutToken = clearTimeout(timeoutToken) as undefined
}
const subscription = delayUnsubscription(unsubscribeGraceTime)(
source$,
).subscribe(nextState => {
setState(nextState as any)
stopInitialState()
timeoutToken = timeoutToken && (clearTimeout(timeoutToken) as undefined)
})
return () => subscription.unsubscribe()