Hopefully there would be a way to restructure this so that you’re not needing to manually create Observable
s, but I can tell you what the fundamental problem is, because it bit me as well. forkJoin
waits for all of its children to complete (not just emit something), and if any of them don’t, it will turn into a mysterious black hole. So the first thing I would try is adding observer.complete()
calls after the places where you call next()
.
1 Like