Skip to content
This repository was archived by the owner on Oct 30, 2023. It is now read-only.

Commit d74588f

Browse files
authored
Merge pull request #190 from brintal/master
Custom dispatcher for sharedClient to allow for more parallel requests.
2 parents 7a1fc4f + d39139a commit d74588f

1 file changed

Lines changed: 12 additions & 3 deletions

File tree

src/main/java/com/binance/api/client/impl/BinanceApiServiceGenerator.java

Lines changed: 12 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44
import com.binance.api.client.constant.BinanceApiConstants;
55
import com.binance.api.client.exception.BinanceApiException;
66
import com.binance.api.client.security.AuthenticationInterceptor;
7+
import okhttp3.Dispatcher;
78
import okhttp3.OkHttpClient;
89
import okhttp3.RequestBody;
910
import okhttp3.ResponseBody;
@@ -22,12 +23,20 @@
2223
* Generates a Binance API implementation based on @see {@link BinanceApiService}.
2324
*/
2425
public class BinanceApiServiceGenerator {
25-
private static final OkHttpClient sharedClient = new OkHttpClient.Builder()
26-
.pingInterval(20, TimeUnit.SECONDS)
27-
.build();
2826

27+
private static final OkHttpClient sharedClient;
2928
private static final Converter.Factory converterFactory = JacksonConverterFactory.create();
3029

30+
static {
31+
Dispatcher dispatcher = new Dispatcher();
32+
dispatcher.setMaxRequestsPerHost(500);
33+
dispatcher.setMaxRequests(500);
34+
sharedClient = new OkHttpClient.Builder()
35+
.dispatcher(dispatcher)
36+
.pingInterval(20, TimeUnit.SECONDS)
37+
.build();
38+
}
39+
3140
@SuppressWarnings("unchecked")
3241
private static final Converter<ResponseBody, BinanceApiError> errorBodyConverter =
3342
(Converter<ResponseBody, BinanceApiError>)converterFactory.responseBodyConverter(

0 commit comments

Comments
 (0)