I haven't actually have seem anything about nx-js before this thread, and I liked a lot the whole approach and the explanation/argument you gave here.

I'm working on something that will use xstream reactive streams and @nx-js/observer-util (previously I tried to do my own MobX-like take on observables, then I jumped into using MobX itself). I'll hope you notice it somewhere someday and give me some feedback.,