Skip to content

Commit 381ce0b

Browse files
feat(arkruntime): add call timeout for ark service builder
1 parent ba4d89e commit 381ce0b

File tree

1 file changed

+7
-1
lines changed
  • volcengine-java-sdk-ark-runtime/src/main/java/com/volcengine/ark/runtime/service

1 file changed

+7
-1
lines changed

volcengine-java-sdk-ark-runtime/src/main/java/com/volcengine/ark/runtime/service/ArkService.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -339,6 +339,7 @@ public static class Builder {
339339
private String region = BASE_REGION;
340340
private String baseUrl = BASE_URL;
341341
private Duration timeout = DEFAULT_TIMEOUT;
342+
private Duration callTimeout;
342343
private Duration connectTimeout = DEFAULT_CONNECT_TIMEOUT;
343344
private int retryTimes = DEFAULT_RETRY_TIMES;
344345
private Proxy proxy;
@@ -379,6 +380,11 @@ public ArkService.Builder timeout(Duration timeout) {
379380
return this;
380381
}
381382

383+
public ArkService.Builder callTimeout(Duration callTimeout) {
384+
this.callTimeout = callTimeout;
385+
return this;
386+
}
387+
382388
public ArkService.Builder connectTimeout(Duration connectTimeout) {
383389
this.connectTimeout = connectTimeout;
384390
return this;
@@ -439,7 +445,7 @@ public ArkService build() {
439445
.addInterceptor(new RetryInterceptor(retryTimes))
440446
.addInterceptor(new BatchInterceptor())
441447
.readTimeout(timeout.toMillis(), TimeUnit.MILLISECONDS)
442-
.callTimeout(timeout.toMillis(), TimeUnit.MILLISECONDS)
448+
.callTimeout(callTimeout == null ? timeout.toMillis() : callTimeout.toMillis(), TimeUnit.MILLISECONDS)
443449
.connectTimeout(connectTimeout)
444450
.build();
445451
Retrofit retrofit = defaultRetrofit(client, mapper, baseUrl, callbackExecutor);

0 commit comments

Comments
 (0)