o Let derived SimpleAHC change realm settings

Author: nabcos

src/main/java/com/ning/http/client/SimpleAsyncHttpClient.java

@@ -70,15 +70,18 @@ public class SimpleAsyncHttpClient {
     private final ErrorDocumentBehaviour errorDocumentBehaviour;
     private final SimpleAHCTransferListener listener;
     private final boolean derived;
+    private Realm realm;
 
-    private SimpleAsyncHttpClient(AsyncHttpClientConfig config, RequestBuilder requestBuilder, ThrowableHandler defaultThrowableHandler, ErrorDocumentBehaviour errorDocumentBehaviour, boolean resumeEnabled, AsyncHttpClient ahc, SimpleAHCTransferListener listener) {
+    private SimpleAsyncHttpClient(AsyncHttpClientConfig config, Realm realm, RequestBuilder requestBuilder, ThrowableHandler defaultThrowableHandler,
+            ErrorDocumentBehaviour errorDocumentBehaviour, boolean resumeEnabled, AsyncHttpClient ahc, SimpleAHCTransferListener listener) {
         this.config = config;
         this.requestBuilder = requestBuilder;
         this.defaultThrowableHandler = defaultThrowableHandler;
         this.resumeEnabled = resumeEnabled;
         this.errorDocumentBehaviour = errorDocumentBehaviour;
         this.asyncHttpClient = ahc;
         this.listener = listener;
+        this.realm = realm;
 
         this.derived = ahc != null;
     }
@@ -271,6 +274,8 @@ private Future<Response> execute(RequestBuilder rb, BodyConsumer bodyConsumer, T
             throwableHandler = defaultThrowableHandler;
         }
 
+        rb.setRealm(realm);
+
         Request request = rb.build();
         ProgressAsyncHandler<Response> handler = new BodyConsumerAsyncHandler(bodyConsumer, throwableHandler, errorDocumentBehaviour, request.getUrl(), listener);
 
@@ -383,6 +388,20 @@ public interface DerivedBuilder {
 
         DerivedBuilder setResumableDownload(boolean resume);
 
+        DerivedBuilder setRealmEnconding(String enc);
+
+        DerivedBuilder setRealmUsePreemptiveAuth(boolean usePreemptiveAuth);
+
+        DerivedBuilder setRealmName(String realmName);
+
+        DerivedBuilder setRealmScheme(Realm.AuthScheme scheme);
+
+        DerivedBuilder setRealmPassword(String password);
+
+        DerivedBuilder setRealmPrincipal(String principal);
+
+        DerivedBuilder setRealmDomain(String domain);
+
         SimpleAsyncHttpClient build();
     }
 
@@ -413,6 +432,10 @@ private Builder(SimpleAsyncHttpClient client) {
             this.enableResumableDownload = client.resumeEnabled;
             this.ahc = client.asyncHttpClient();
             this.listener = client.listener;
+
+            if (client.realm != null) {
+                realm().clone(client.realm);
+            }
         }
 
         public Builder addBodyPart(Part part) throws IllegalArgumentException {
@@ -661,8 +684,10 @@ public Builder setMaxRequestRetry(int maxRequestRetry) {
 
         public SimpleAsyncHttpClient build() {
 
+            Realm realm = null;
             if (realmBuilder != null) {
-                configBuilder.setRealm(realmBuilder.build());
+                realm = realmBuilder.build();
+                configBuilder.setRealm(realm);
             }
 
             if (proxyHost != null) {
@@ -671,7 +696,8 @@ public SimpleAsyncHttpClient build() {
 
             configBuilder.addIOExceptionFilter(new ResumableIOExceptionFilter());
 
-            SimpleAsyncHttpClient sc = new SimpleAsyncHttpClient(configBuilder.build(), requestBuilder, defaultThrowableHandler, errorDocumentBehaviour, enableResumableDownload, ahc, listener);
+            SimpleAsyncHttpClient sc = new SimpleAsyncHttpClient(configBuilder.build(), realm, requestBuilder, defaultThrowableHandler,
+                    errorDocumentBehaviour, enableResumableDownload, ahc, listener);
 
             return sc;
         }