Skip to content

Instantly share code, notes, and snippets.

View atetc's full-sized avatar
🎯
Focusing

Rustem Saitkulov atetc

🎯
Focusing
View GitHub Profile
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();