using rxjava instead of java 8 streams