Don't use Observable.create()

[vaughandroid]

See:

• http://stackoverflow.com/documentation/rx-java/2341/backpressure/10629/creating-backpressured-data-sources#t=2016080106581598185
• http://stackoverflow.com/questions/38652377/observable-create-vs-observable-fromasync-in-rxjava