Functional composition of database calls using jdbc and rx-java Observables