Netflix/RxJava — pull request #1291 by mattrjacobs (2014-05-30 17:02:41+00:00)
Title: Check unsubscribe within observable from future

Right now, Observable.from(Future f) emits onError(CancellationException) when f starts out in a cancelled state. This change makes Observable.from(f) emit nothing in this case, and also when an unsubscribe occurs during a Future.get() that results in an Exception.