Efficient execution and functional composition of database calls using jdbc and rx-java Observables