Skip to content

Instantly share code, notes, and snippets.

What would you like to do?
Writing the same code using RxJava Observable
public Observable<Response> processRequest( @QueryParam("id")String id, @QueryParam("userId")String userId ) {
Observable.fromCallable(() -> database.retrieveRecord(id)),
Observable.fromCallable(() -> userStore.retrieve(userId)),
Observable.fromCallable(() -> logger.writeEntryFor(id, userId)),
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.