-
If you look here, it seems to me like after hydration is complete, all other operations that come through will end up getting buffered forever. the hydration fromPromise will never emit again so the buffer will grow and grow. Keeping references to objects that will never ever be used again seems to me like a memory leak. It seems to me like there should be a const inputOps$ = hydration
? share(
merge([
pipe(
sharedOps$,
takeUntil(fromPromise(hydration)),
buffer(fromPromise(hydration)),
mergeMap(fromArray)
),
pipe(sharedOps$, skipUntil(fromPromise(hydration))),
])
)
: sharedOps$; Does wonka's |
Beta Was this translation helpful? Give feedback.
Replies: 1 comment
-
Nevermind, I was looking at |
Beta Was this translation helpful? Give feedback.
Nevermind, I was looking at
wonka
code and it looks likefromPromise
will emit anEnd
that will turn off the buffer. Nothing to see here, no memory leak!