implements TODO duplicate with error inside async Observables

I've been going over the code trying to better understand reactive Hystrix / RxJava Observables.  This is my stab at changing the couple reactive tests with TODOs to simulate the errors in the Observable.