@Test
public void testEmitError() {

    Optional<Throwable> error = ReactorExt.emitError(Mono.error(new RuntimeException("SimulatedError"))).single().block();
    assertThat(error).isPresent();
    assertThat(error.get()).isInstanceOf(RuntimeException.class);
}