3838import io .github .resilience4j .circuitbreaker .CircuitBreaker ;
3939import io .github .resilience4j .circuitbreaker .CircuitBreakerConfig ;
4040import io .github .resilience4j .circuitbreaker .CircuitBreakerRegistry ;
41+ import io .github .resilience4j .core .functions .CheckedSupplier ;
4142import io .github .resilience4j .decorators .Decorators ;
4243import io .github .resilience4j .retry .Retry ;
4344import io .github .resilience4j .retry .RetryConfig ;
4445import io .github .resilience4j .retry .RetryRegistry ;
45- import io .vavr .CheckedFunction0 ;
4646import io .vavr .control .Try ;
4747import org .bouncycastle .asn1 .ocsp .OCSPResponseStatus ;
4848import org .bouncycastle .cert .ocsp .BasicOCSPResp ;
@@ -115,18 +115,18 @@ public List<RevocationInfo> validateCertificateNotRevoked(X509Certificate subjec
115115
116116 List <RevocationInfo > revocationInfoList = new ArrayList <>();
117117
118- CheckedFunction0 <RevocationInfo > primarySupplier = () -> request (ocspService , subjectCertificate , issuerCertificate , false );
118+ CheckedSupplier <RevocationInfo > primarySupplier = () -> request (ocspService , subjectCertificate , issuerCertificate , false );
119119 OcspService firstFallbackService = ocspService .getFallbackService ();
120- CheckedFunction0 <RevocationInfo > firstFallbackSupplier = () -> request (firstFallbackService , subjectCertificate , issuerCertificate , true );
120+ CheckedSupplier <RevocationInfo > firstFallbackSupplier = () -> request (firstFallbackService , subjectCertificate , issuerCertificate , true );
121121 OcspService secondFallbackService = getOcspServiceProvider ().getFallbackService (firstFallbackService .getAccessLocation ());
122- CheckedFunction0 <RevocationInfo > fallbackSupplier ;
122+ CheckedSupplier <RevocationInfo > fallbackSupplier ;
123123 if (secondFallbackService == null ) {
124124 fallbackSupplier = firstFallbackSupplier ;
125125 } else {
126- CheckedFunction0 <RevocationInfo > secondFallbackSupplier = () -> request (secondFallbackService , subjectCertificate , issuerCertificate , true );
126+ CheckedSupplier <RevocationInfo > secondFallbackSupplier = () -> request (secondFallbackService , subjectCertificate , issuerCertificate , true );
127127 fallbackSupplier = () -> {
128128 try {
129- return firstFallbackSupplier .apply ();
129+ return firstFallbackSupplier .get ();
130130 } catch (ResilientUserCertificateRevokedException e ) {
131131 // NOTE: ResilientUserCertificateRevokedException must be re-thrown before the generic
132132 // catch (Exception) block. Without this, a "revoked" verdict from the first fallback would
@@ -140,7 +140,7 @@ public List<RevocationInfo> validateCertificateNotRevoked(X509Certificate subjec
140140 Map .entry (RevocationInfo .KEY_OCSP_ERROR , e )
141141 )));
142142 }
143- return secondFallbackSupplier .apply ();
143+ return secondFallbackSupplier .get ();
144144 }
145145 };
146146 }
@@ -159,12 +159,12 @@ public List<RevocationInfo> validateCertificateNotRevoked(X509Certificate subjec
159159 decorateCheckedSupplier .withCircuitBreaker (circuitBreaker )
160160 .withFallback (List .of (ResilientUserCertificateOCSPCheckFailedException .class , CallNotPermittedException .class ), e -> {
161161 createAndAddRevocationInfoToList (e , revocationInfoList );
162- return fallbackSupplier .apply ();
162+ return fallbackSupplier .get ();
163163 });
164164
165- CheckedFunction0 <RevocationInfo > decoratedSupplier = decorateCheckedSupplier .decorate ();
165+ CheckedSupplier <RevocationInfo > decoratedSupplier = decorateCheckedSupplier .decorate ();
166166
167- Try <RevocationInfo > result = Try .of (decoratedSupplier );
167+ Try <RevocationInfo > result = Try .of (decoratedSupplier :: get );
168168
169169 RevocationInfo revocationInfo = result .getOrElseThrow (throwable -> {
170170 if (throwable instanceof ResilientUserCertificateOCSPCheckFailedException exception ) {
0 commit comments