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 (Exception e ) {
131131 if (e instanceof ResilientUserCertificateOCSPCheckFailedException exception ) {
132132 revocationInfoList .addAll ((exception .getValidationInfo ().revocationInfoList ()));
@@ -135,7 +135,7 @@ public List<RevocationInfo> validateCertificateNotRevoked(X509Certificate subjec
135135 Map .entry (RevocationInfo .KEY_OCSP_ERROR , e )
136136 )));
137137 }
138- return secondFallbackSupplier .apply ();
138+ return secondFallbackSupplier .get ();
139139 }
140140 };
141141 }
@@ -154,12 +154,12 @@ public List<RevocationInfo> validateCertificateNotRevoked(X509Certificate subjec
154154 decorateCheckedSupplier .withCircuitBreaker (circuitBreaker )
155155 .withFallback (List .of (ResilientUserCertificateOCSPCheckFailedException .class , CallNotPermittedException .class ), e -> {
156156 createAndAddRevocationInfoToList (e , revocationInfoList );
157- return fallbackSupplier .apply ();
157+ return fallbackSupplier .get ();
158158 });
159159
160- CheckedFunction0 <RevocationInfo > decoratedSupplier = decorateCheckedSupplier .decorate ();
160+ CheckedSupplier <RevocationInfo > decoratedSupplier = decorateCheckedSupplier .decorate ();
161161
162- Try <RevocationInfo > result = Try .of (decoratedSupplier );
162+ Try <RevocationInfo > result = Try .of (decoratedSupplier :: get );
163163
164164 RevocationInfo revocationInfo = result .getOrElseThrow (throwable -> {
165165 if (throwable instanceof ResilientUserCertificateOCSPCheckFailedException exception ) {
0 commit comments