Update to 0.16.1

Updated to rxjava 0.16.1
Adjusted to match the new API.

Thanks for the examples