code: private static <T> Consumer<T> throwingConsumerWrapper(
  			ThrowingConsumer<T, Exception> throwingConsumer) {
  
  		return i -> {
  			try {
  				throwingConsumer.accept(i);
  			} catch (Exception ex) {
  				throw new RetryExceptionWrapper(ex);
  			}
  		};
  	}
docs: to handle checked exception handling in reactor Function java 8 doOnNext