Reactive system example with RxJava