To answer the original question, use Observable.fr...

# rx

[jw]

To answer the original question, use Observable.fromCallable to wrap the synchronous request, add subscribeOn with the thread on which you want it to execute, and then flatMap that into the click stream.