Change signature of Observable.from(Future) to handle re-subscription