RxJavaExceptionTestingTest.java

public class RxJavaExceptionTestingTest {

	private RxJavaExceptionTesting exceptionTesting;

	@Before
	public void initialize(){
		exceptionTesting = new RxJavaExceptionTesting();
	}
	
	@Test
	public void foo1() throws Exception {
		exceptionTesting.foo1()
				.test()
				.assertNoErrors();
	}

	@Test
	public void foo2() throws Exception {
		exceptionTesting.foo2()
				.test()
				.assertError(MyException.class)
				.assertError(new MyException());
	}

	@Test
	public void foo3() throws Exception {
		exceptionTesting.foo3()
				.test()
				.assertError(MyException.class)
				.assertError(throwable -> "This is a custom exception.".equals(throwable.getMessage()));
	}

}