RxJavaExceptionTesting.java

public final class RxJavaExceptionTesting {

	public Observable<String> foo1() {
		return Observable.empty();
	}

	public Observable<String> foo2() {
		return Observable.error(new MyException());
	}

	public Observable<String> foo3() {
		return Observable.error(new MyException("This is a custom exception."));
	}
	
}

class MyException extends Exception {

	private String message;

	public MyException() {
		super();
		this.message ="";
	}

	public MyException(String message) {
		super(message);
		this.message = message;
	}

	@Override
	public boolean equals(final Object obj) {
		return obj != null 
				&& obj instanceof MyException 
				&& Objects.equals(message, ((MyException) obj).message);
	}
}