This PR is 9 days old. I have more experience with lock-free approaches since then. I'll revisit these classes and will fix the onNext under lock issues.