@Test
@Ignore("Observers can't throw")
public void testOnCompletedThrows() {

    final AtomicReference<Throwable> error = new AtomicReference<Throwable>();
    SafeObserver<Integer> s = new SafeObserver<Integer>(new DefaultObserver<Integer>() {
        @Override
        public void onNext(Integer t) {
        }
        @Override
        public void onError(Throwable e) {
            error.set(e);
        }
        @Override
        public void onComplete() {
            throw new TestException();
        }
    });
    try {
        s.onComplete();
        Assert.fail();
    } catch (RuntimeException e) {
       assertNull(error.get());
    }
}