public static SdkAsyncHttpClient createAsyncHttpClient()

in flink-connector-aws-base/src/main/java/org/apache/flink/connector/aws/util/AWSGeneralUtil.java [297:336]
36 lines of code
1 McCabe index (conditional complexity)

    public static SdkAsyncHttpClient createAsyncHttpClient(
            final Properties configProperties,
            final NettyNioAsyncHttpClient.Builder httpClientBuilder) {
        final AttributeMap.Builder clientConfiguration =
                AttributeMap.builder().put(SdkHttpConfigurationOption.TCP_KEEPALIVE, true);

        Optional.ofNullable(
                        configProperties.getProperty(
                                AWSConfigConstants.HTTP_CLIENT_MAX_CONCURRENCY))
                .map(Integer::parseInt)
                .ifPresent(
                        integer ->
                                clientConfiguration.put(
                                        SdkHttpConfigurationOption.MAX_CONNECTIONS, integer));

        Optional.ofNullable(
                        configProperties.getProperty(
                                AWSConfigConstants.HTTP_CLIENT_READ_TIMEOUT_MILLIS))
                .map(Integer::parseInt)
                .map(Duration::ofMillis)
                .ifPresent(
                        timeout ->
                                clientConfiguration.put(
                                        SdkHttpConfigurationOption.READ_TIMEOUT, timeout));

        Optional.ofNullable(configProperties.getProperty(AWSConfigConstants.TRUST_ALL_CERTIFICATES))
                .map(Boolean::parseBoolean)
                .ifPresent(
                        bool ->
                                clientConfiguration.put(
                                        SdkHttpConfigurationOption.TRUST_ALL_CERTIFICATES, bool));

        Optional.ofNullable(configProperties.getProperty(AWSConfigConstants.HTTP_PROTOCOL_VERSION))
                .map(Protocol::valueOf)
                .ifPresent(
                        protocol ->
                                clientConfiguration.put(
                                        SdkHttpConfigurationOption.PROTOCOL, protocol));
        return createAsyncHttpClient(clientConfiguration.build(), httpClientBuilder);
    }