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