This is the example code from my presentation Consuming web services asynchronously with Futures and Rx Observables