xcolwell

    public void testExceptionSubjectObserverCustomThrow() {
        // setup:
        // subject -> observer
        // shows that an exception in observer#onNext will call observer#onError,
        // and that an unahndled exception in observer#onError will come back to the caller


        BehaviorSubject<Integer> subject = BehaviorSubject.create();