Skip to content

Commit a48bc3a

Browse files
authored
Propagate connect timeout to HttpClient (#182)
1 parent 9ac9fa0 commit a48bc3a

2 files changed

Lines changed: 6 additions & 0 deletions

File tree

src/main/java/dev/openfga/sdk/api/OpenFgaApi.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -90,6 +90,11 @@ public OpenFgaApi(Configuration configuration, ApiClient apiClient) throws FgaIn
9090
if (defaultHeaders != null) {
9191
apiClient.addRequestInterceptor(httpRequest -> defaultHeaders.forEach(httpRequest::setHeader));
9292
}
93+
94+
Duration connectTimeout = configuration.getConnectTimeout();
95+
if (connectTimeout != null) {
96+
apiClient.setHttpClientBuilder(apiClient.getHttpClientBuilder().connectTimeout(connectTimeout));
97+
}
9398
}
9499

95100
/**

src/main/java/dev/openfga/sdk/api/auth/OAuth2Client.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,7 @@ public OAuth2Client(Configuration configuration, ApiClient apiClient) throws Fga
4949
this.authRequest.setScope(clientCredentials.getScopes());
5050
this.config = new Configuration()
5151
.apiUrl(buildApiTokenIssuer(clientCredentials.getApiTokenIssuer()))
52+
.connectTimeout(configuration.getConnectTimeout())
5253
.maxRetries(configuration.getMaxRetries())
5354
.minimumRetryDelay(configuration.getMinimumRetryDelay())
5455
.telemetryConfiguration(configuration.getTelemetryConfiguration());

0 commit comments

Comments
 (0)