I'm glad you brought RxJS up. Yes, there are some similarities between Reactive and PubSub pattern but they solve different problems. What's cool about this implementation of Omnibus is that it's fully compatible with RxJS `fromEvent` function so you can easily convert between those: https://gist.github.com/kulak-at/64100312ac089953a9eb8fee79b78e12