@Test
public void onError() throws Exception {

  Exception exception = new Exception();
  underTest.subscribe(subscriber);
  underTest.onError(exception);
  underTest.onError(exception);
  verify(subscriber, times(1)).onError(exception);
}