- * AsyncHandler ah = new AsyncHandler() {....};
- * AsyncHttpClient client = new AsyncHttpClient();
- * client.prepareGet("http://.../").execute(ah);
- * client.prepareGet("http://.../").execute(ah);
- * - * The code above will block until the response is fully received. To execute asynchronous HTTP request, you - * create an {@link AsyncHandler} or its abstract implementation, {@link AsyncCompletionHandler} - * - *- * AsyncHttpClient c = new AsyncHttpClient(); - * Futuref = c.prepareGet("http://www.ning.com/").execute(); - *
- * You can also have more control about the how the response is asynchronously processed by using a {@link AsyncHandler} - *- * AsyncHttpClient c = new AsyncHttpClient(); - * Futuref = c.prepareGet("http://www.ning.com/").execute(new AsyncCompletionHandler () { - * - * @Override - * public Response onCompleted(Response response) throws IOException { - * // Do something - * return response; - * } - * - * @Override - * public void onThrowable(Throwable t) { - * } - * }); - * Response response = f.get(); - * - * // We are just interested to retrieve the status code. - * Future f = c.prepareGet("http://www.ning.com/").execute(new AsyncCompletionHandler () { - * - * @Override - * public Integer onCompleted(Response response) throws IOException { - * // Do something - * return response.getStatusCode(); - * } - * - * @Override - * public void onThrowable(Throwable t) { - * } - * }); - * Integer statusCode = f.get(); - *
- * This class can also be used without the need of {@link AsyncHandler} - *- * AsyncHttpClient c = new AsyncHttpClient(); - * Futuref = c.prepareGet("http://www.ning.com/").execute(new AsyncHandler () { - * private StringBuilder builder = new StringBuilder(); - * - * @Override - * public STATE onStatusReceived(HttpResponseStatus s) throws Exception { - * // return STATE.CONTINUE or STATE.ABORT - * return STATE.CONTINUE - * } - * - * @Override - * public STATE onHeadersReceived(HttpResponseHeaders bodyPart) throws Exception { - * // return STATE.CONTINUE or STATE.ABORT - * return STATE.CONTINUE - * - * } - * @Override - * - * public STATE onBodyPartReceived(HttpResponseBodyPart bodyPart) throws Exception { - * builder.append(new String(bodyPart)); - * // return STATE.CONTINUE or STATE.ABORT - * return STATE.CONTINUE - * } - * - * @Override - * public String onCompleted() throws Exception { - * // Will be invoked once the response has been fully read or a ResponseComplete exception - * // has been thrown. - * return builder.toString(); - * } - * - * @Override - * public void onThrowable(Throwable t) { - * } - * }); - * - * String bodyResponse = f.get(); - *
- * - * Finally, you can configure the AsyncHttpClient using an {@link AsyncHttpClientConfig} instance - *- * AsyncHttpClient c = new AsyncHttpClient(); - * Futuref = c.prepareGet(TARGET_URL).execute(); - * Response r = f.get(); - *
- * - * An instance of this class will cache every HTTP 1.1 connections and close them when the {@link AsyncHttpClientConfig#getReadTimeout()} - * expires. This object can hold many persistent connections to different host. - */ -public interface AsyncHttpClient extends Closeable { - - /** - * Return the asynchronous {@link AsyncHttpProvider} - * - * @return an {@link AsyncHttpProvider} - */ - AsyncHttpProvider getProvider(); - - /** - * Close the underlying connections. - */ - void close(); - - /** - * Asynchronous close the {@link AsyncHttpProvider} by spawning a thread and avoid blocking. - */ - void closeAsynchronously(); - - /** - * Return true if closed - * - * @return true if closed - */ - boolean isClosed(); - - /** - * Return the {@link AsyncHttpClientConfig} - * - * @return {@link AsyncHttpClientConfig} - */ - AsyncHttpClientConfig getConfig(); - - /** - * Set default signature calculator to use for requests build by this client instance - */ - AsyncHttpClient setSignatureCalculator(SignatureCalculator signatureCalculator); - - /** - * Prepare an HTTP client GET request. - * - * @param url A well formed URL. - * @return {@link RequestBuilder} - */ - BoundRequestBuilder prepareGet(String url); - - /** - * Prepare an HTTP client CONNECT request. - * - * @param url A well formed URL. - * @return {@link RequestBuilder} - */ - BoundRequestBuilder prepareConnect(String url); - - /** - * Prepare an HTTP client OPTIONS request. - * - * @param url A well formed URL. - * @return {@link RequestBuilder} - */ - BoundRequestBuilder prepareOptions(String url); - - /** - * Prepare an HTTP client HEAD request. - * - * @param url A well formed URL. - * @return {@link RequestBuilder} - */ - BoundRequestBuilder prepareHead(String url); - - /** - * Prepare an HTTP client POST request. - * - * @param url A well formed URL. - * @return {@link RequestBuilder} - */ - BoundRequestBuilder preparePost(String url); - - /** - * Prepare an HTTP client PUT request. - * - * @param url A well formed URL. - * @return {@link RequestBuilder} - */ - BoundRequestBuilder preparePut(String url); - - /** - * Prepare an HTTP client DELETE request. - * - * @param url A well formed URL. - * @return {@link RequestBuilder} - */ - BoundRequestBuilder prepareDelete(String url); - - /** - * Prepare an HTTP client PATCH request. - * - * @param url A well formed URL. - * @return {@link RequestBuilder} - */ - BoundRequestBuilder preparePatch(String url); - - /** - * Prepare an HTTP client TRACE request. - * - * @param url A well formed URL. - * @return {@link RequestBuilder} - */ - BoundRequestBuilder prepareTrace(String url); - - /** - * Construct a {@link RequestBuilder} using a {@link Request} - * - * @param request a {@link Request} - * @return {@link RequestBuilder} - */ - BoundRequestBuilder prepareRequest(Request request); - - /** - * Execute an HTTP request. - * - * @param request {@link Request} - * @param handler an instance of {@link AsyncHandler} - * @param- * AsyncHttpClient c = new AsyncHttpClient(new AsyncHttpClientConfig.Builder().setRequestTimeoutInMs(...).build()); - * Futuref = c.prepareGet(TARGET_URL).execute(); - * Response r = f.get(); - *
null
- */
- public ExecutorService executorService() {
- return applicationThreadPool;
- }
-
- /**
- * An instance of {@link ProxyServer} used by an {@link AsyncHttpClient}
- *
- * @return instance of {@link ProxyServer}
- */
- public ProxyServerSelector getProxyServerSelector() {
- return proxyServerSelector;
- }
-
- /**
- * Return an instance of {@link SSLContext} used for SSL connection.
- *
- * @return an instance of {@link SSLContext} used for SSL connection.
- */
- public SSLContext getSSLContext() {
- return sslContext;
- }
-
- /**
- * Return the {@link AsyncHttpProviderConfig}
- *
- * @return the {@link AsyncHttpProviderConfig}
- */
- public AsyncHttpProviderConfig getAsyncHttpProviderConfig() {
- return providerConfig;
- }
-
- /**
- * Return the current {@link Realm}}
- *
- * @return the current {@link Realm}}
- */
- public Realm getRealm() {
- return realm;
- }
-
- /**
- * @return true if {@link RequestFilter}s have been defined.
- *
- * @since 2.0.0
- */
- public boolean hasRequestFilters() {
- return !requestFilters.isEmpty();
- }
-
- /**
- * Return the list of {@link RequestFilter}
- *
- * @return Unmodifiable list of {@link ResponseFilter}
- */
- public Listtrue if {@link ResponseFilter}s have been defined.
- * @since 2.0.0
- */
- public boolean hasResponseFilters() {
- return !responseFilters.isEmpty();
- }
-
- /**
- * Return the list of {@link ResponseFilter}
- *
- * @return Unmodifiable list of {@link ResponseFilter}
- */
- public Listtrue if both the application and reaper thread pools
- * haven't yet been shutdown.
- * @since 1.7.21
- */
- public boolean isValid() {
- boolean atpRunning = true;
- try {
- atpRunning = applicationThreadPool.isShutdown();
- } catch (Exception ignore) {
- // isShutdown() will thrown an exception in an EE7 environment
- // when using a ManagedExecutorService.
- // When this is the case, we assume it's running.
- }
- return atpRunning;
- }
-
- /**
- * Return the {@link HostnameVerifier}
- *
- * @return the {@link HostnameVerifier}
- */
- public HostnameVerifier getHostnameVerifier() {
- return hostnameVerifier;
- }
-
- /**
- * @return number to multiply by availableProcessors() that will determine # of NioWorkers to use
- */
- public int getIoThreadMultiplier() {
- return ioThreadMultiplier;
- }
-
- /**
- * - * In the case of a POST/Redirect/Get scenario where the server uses a 302 - * for the redirect, should AHC respond to the redirect with a GET or - * whatever the original method was. Unless configured otherwise, - * for a 302, AHC, will use a GET for this case. - *
- * - * @returntrue if string 302 handling is to be used,
- * otherwise false.
- *
- * @since 1.7.2
- */
- public boolean isStrict302Handling() {
- return strict302Handling;
- }
-
- /**
- * @returntrue if AHC should use relative URIs instead of absolute ones when talking with a SSL proxy
- * or WebSocket proxy, otherwise false.
- *
- * @since 1.8.13
- */
- public boolean isUseRelativeURIsWithConnectProxies() {
- return useRelativeURIsWithConnectProxies;
- }
-
- /**
- * Return the maximum time in millisecond an {@link AsyncHttpClient} will keep connection in the pool, or -1 to keep connection while possible.
- *
- * @return the maximum time in millisecond an {@link AsyncHttpClient} will keep connection in the pool, or -1 to keep connection while possible.
- */
- public int getConnectionTTL() {
- return connectionTTL;
- }
-
- /**
- * @return the TimeConverter used for converting RFC2616Dates into time
- *
- * @since 2.0.0
- */
- public TimeConverter getTimeConverter() {
- return timeConverter;
- }
-
- public boolean isAcceptAnyCertificate() {
- return acceptAnyCertificate;
- }
-
- /**
- * Builder for an {@link AsyncHttpClient}
- */
- public static class Builder {
- private int connectTimeout = defaultConnectTimeout();
- private int maxConnections = defaultMaxConnections();
- private int maxConnectionsPerHost = defaultMaxConnectionsPerHost();
- private int requestTimeout = defaultRequestTimeout();
- private int readTimeout = defaultReadTimeout();
- private int webSocketTimeout = defaultWebSocketTimeout();
- private boolean allowPoolingConnections = defaultAllowPoolingConnections();
- private boolean allowPoolingSslConnections = defaultAllowPoolingSslConnections();
- private int pooledConnectionIdleTimeout = defaultPooledConnectionIdleTimeout();
- private int connectionTTL = defaultConnectionTTL();
- private SSLContext sslContext;
- private HostnameVerifier hostnameVerifier;
- private boolean acceptAnyCertificate = defaultAcceptAnyCertificate();
- private boolean followRedirect = defaultFollowRedirect();
- private int maxRedirects = defaultMaxRedirects();
- private boolean removeQueryParamOnRedirect = defaultRemoveQueryParamOnRedirect();
- private boolean strict302Handling = defaultStrict302Handling();
- private ProxyServerSelector proxyServerSelector = null;
- private boolean useProxySelector = defaultUseProxySelector();
- private boolean useProxyProperties = defaultUseProxyProperties();
- private boolean useRelativeURIsWithConnectProxies = defaultUseRelativeURIsWithConnectProxies();
- private boolean compressionEnforced = defaultCompressionEnforced();
- private String userAgent = defaultUserAgent();
- private ExecutorService applicationThreadPool;
- private Realm realm;
- private final Listtrue but {@link #setProxyServer(ProxyServer)}
- * was used to explicitly set a proxy server, the latter is preferred.
- *
- * See http://docs.oracle.com/javase/7/docs/api/java/net/ProxySelector.html
- */
- public Builder setUseProxySelector(boolean useProxySelector) {
- this.useProxySelector = useProxySelector;
- return this;
- }
-
- /**
- * Sets whether AHC should use the default http.proxy* system properties
- * to obtain proxy information. This differs from {@link #setUseProxySelector(boolean)}
- * in that AsyncHttpClient will use its own logic to handle the system properties,
- * potentially supporting other protocols that the the JDK ProxySelector doesn't.
- *
- * If useProxyProperties is set to true but {@link #setUseProxySelector(boolean)}
- * was also set to true, the latter is preferred.
- *
- * See http://download.oracle.com/javase/1.4.2/docs/guide/net/properties.html
- */
- public Builder setUseProxyProperties(boolean useProxyProperties) {
- this.useProxyProperties = useProxyProperties;
- return this;
- }
-
- public Builder setIOThreadMultiplier(int multiplier) {
- this.ioThreadMultiplier = multiplier;
- return this;
- }
-
- /**
- * Set the {@link HostnameVerifier}
- *
- * @param hostnameVerifier {@link HostnameVerifier}
- * @return this
- */
- public Builder setHostnameVerifier(HostnameVerifier hostnameVerifier) {
- this.hostnameVerifier = hostnameVerifier;
- return this;
- }
-
- /**
- * Configures this AHC instance to be strict in it's handling of 302 redirects
- * in a POST/Redirect/GET situation.
- *
- * @param strict302Handling strict handling
- *
- * @return this
- *
- * @since 1.7.2
- */
- public Builder setStrict302Handling(final boolean strict302Handling) {
- this.strict302Handling = strict302Handling;
- return this;
- }
-
- /**
- * Set the maximum time in millisecond connection can be added to the pool for further reuse
- *
- * @param connectionTTL the maximum time in millisecond connection can be added to the pool for further reuse
- * @return a {@link Builder}
- */
- public Builder setConnectionTTL(int connectionTTL) {
- this.connectionTTL = connectionTTL;
- return this;
- }
-
- /**
- * Configures this AHC instance to use relative URIs instead of absolute ones when talking with a SSL or WebSocket proxy.
- *
- * @param useRelativeURIsWithConnectProxies
- * @return this
- *
- * @since 1.7.2
- */
- public Builder setUseRelativeURIsWithConnectProxies(boolean useRelativeURIsWithConnectProxies) {
- this.useRelativeURIsWithConnectProxies = useRelativeURIsWithConnectProxies;
- return this;
- }
-
- /**
- * Enables SPDY support. Note that doing so, will currently disable WebSocket support
- * for this client instance. If not explicitly enabled, spdy will not be used.
- *
- * @param spdyEnabled configures spdy support.
- *
- * @return this
- *
- * @since 2.0
- */
- public Builder setSpdyEnabled(boolean spdyEnabled) {
- this.spdyEnabled = spdyEnabled;
- return this;
- }
-
- /**
- * Configures the initial window size for the SPDY session.
- *
- * @param spdyInitialWindowSize the initial window size.
- *
- * @return this
- *
- * @since 2.0
- */
- public Builder setSpdyInitialWindowSize(int spdyInitialWindowSize) {
- this.spdyInitialWindowSize = spdyInitialWindowSize;
- return this;
- }
-
- /**
- * Configures the maximum number of concurrent streams over a single
- * SPDY session.
- *
- * @param spdyMaxConcurrentStreams the maximum number of concurrent
- * streams over a single SPDY session.
- *
- * @return this
- *
- * @since 2.0
- */
- public Builder setSpdyMaxConcurrentStreams(int spdyMaxConcurrentStreams) {
- this.spdyMaxConcurrentStreams = spdyMaxConcurrentStreams;
- return this;
- }
-
- public Builder setTimeConverter(TimeConverter timeConverter) {
- this.timeConverter = timeConverter;
- return this;
- }
-
- public Builder setAcceptAnyCertificate(boolean acceptAnyCertificate) {
- this.acceptAnyCertificate = acceptAnyCertificate;
- return this;
- }
-
- /**
- * Create a config builder with values taken from the given prototype configuration.
- *
- * @param prototype the configuration to use as a prototype.
- */
- public Builder(AsyncHttpClientConfig prototype) {
- allowPoolingConnections = prototype.isAllowPoolingConnections();
- providerConfig = prototype.getAsyncHttpProviderConfig();
- connectTimeout = prototype.getConnectTimeout();
- pooledConnectionIdleTimeout = prototype.getPooledConnectionIdleTimeout();
- readTimeout = prototype.getReadTimeout();
- maxConnectionsPerHost = prototype.getMaxConnectionsPerHost();
- connectionTTL = prototype.getConnectionTTL();
- maxRedirects = prototype.getMaxRedirects();
- maxConnections = prototype.getMaxConnections();
- proxyServerSelector = prototype.getProxyServerSelector();
- realm = prototype.getRealm();
- requestTimeout = prototype.getRequestTimeout();
- sslContext = prototype.getSSLContext();
- userAgent = prototype.getUserAgent();
- followRedirect = prototype.isFollowRedirect();
- compressionEnforced = prototype.isCompressionEnforced();
- applicationThreadPool = prototype.executorService();
-
- requestFilters.clear();
- responseFilters.clear();
- ioExceptionFilters.clear();
-
- requestFilters.addAll(prototype.getRequestFilters());
- responseFilters.addAll(prototype.getResponseFilters());
- ioExceptionFilters.addAll(prototype.getIOExceptionFilters());
-
- disableUrlEncodingForBoundRequests = prototype.isDisableUrlEncodingForBoundRequests();
- ioThreadMultiplier = prototype.getIoThreadMultiplier();
- maxRequestRetry = prototype.getMaxRequestRetry();
- allowPoolingSslConnections = prototype.isAllowPoolingConnections();
- removeQueryParamOnRedirect = prototype.isRemoveQueryParamOnRedirect();
- hostnameVerifier = prototype.getHostnameVerifier();
- strict302Handling = prototype.isStrict302Handling();
- timeConverter = prototype.timeConverter;
- acceptAnyCertificate = prototype.acceptAnyCertificate;
-
- spdyEnabled = prototype.isSpdyEnabled();
- spdyInitialWindowSize = prototype.getSpdyInitialWindowSize();
- spdyMaxConcurrentStreams = prototype.getSpdyMaxConcurrentStreams();
- }
-
- /**
- * Build an {@link AsyncHttpClientConfig}
- *
- * @return an {@link AsyncHttpClientConfig}
- */
- public AsyncHttpClientConfig build() {
-
- if (proxyServerSelector == null && useProxySelector)
- proxyServerSelector = ProxyUtils.getJdkDefaultProxyServerSelector();
-
- if (proxyServerSelector == null && useProxyProperties)
- proxyServerSelector = ProxyUtils.createProxyServerSelector(System.getProperties());
-
- if (proxyServerSelector == null)
- proxyServerSelector = ProxyServerSelector.NO_PROXY_SELECTOR;
-
- if (acceptAnyCertificate)
- hostnameVerifier = null;
- else if (hostnameVerifier == null)
- hostnameVerifier = new DefaultHostnameVerifier();
-
- return new AsyncHttpClientConfig(connectTimeout,//
- maxConnections,//
- maxConnectionsPerHost,//
- requestTimeout,//
- readTimeout,//
- webSocketTimeout,//
- allowPoolingConnections,//
- allowPoolingSslConnections,//
- pooledConnectionIdleTimeout,//
- connectionTTL,//
- sslContext, //
- hostnameVerifier,//
- acceptAnyCertificate, //
- followRedirect, //
- maxRedirects, //
- removeQueryParamOnRedirect,//
- strict302Handling, //
- applicationThreadPool, //
- proxyServerSelector, //
- useRelativeURIsWithConnectProxies, //
- compressionEnforced, //
- userAgent,//
- realm,//
- requestFilters, //
- responseFilters,//
- ioExceptionFilters,//
- maxRequestRetry, //
- disableUrlEncodingForBoundRequests, //
- ioThreadMultiplier, //
- timeConverter,//
- providerConfig, //
- spdyEnabled, //
- spdyInitialWindowSize, //
- spdyMaxConcurrentStreams);
- }
- }
-}
diff --git a/api/src/main/java/org/asynchttpclient/AsyncHttpClientConfigBean.java b/api/src/main/java/org/asynchttpclient/AsyncHttpClientConfigBean.java
deleted file mode 100644
index 610735f642..0000000000
--- a/api/src/main/java/org/asynchttpclient/AsyncHttpClientConfigBean.java
+++ /dev/null
@@ -1,238 +0,0 @@
-/*
- * Copyright (c) 2010-2012 Sonatype, Inc. All rights reserved.
- *
- * This program is licensed to you under the Apache License Version 2.0,
- * and you may not use this file except in compliance with the Apache License Version 2.0.
- * You may obtain a copy of the Apache License Version 2.0 at http://www.apache.org/licenses/LICENSE-2.0.
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the Apache License Version 2.0 is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the Apache License Version 2.0 for the specific language governing permissions and limitations there under.
- */
-package org.asynchttpclient;
-
-import static org.asynchttpclient.AsyncHttpClientConfigDefaults.*;
-
-import org.asynchttpclient.filter.IOExceptionFilter;
-import org.asynchttpclient.filter.RequestFilter;
-import org.asynchttpclient.filter.ResponseFilter;
-import org.asynchttpclient.util.ProxyUtils;
-
-import javax.net.ssl.HostnameVerifier;
-import javax.net.ssl.SSLContext;
-
-import java.util.LinkedList;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.concurrent.ThreadFactory;
-
-/**
- * Simple JavaBean version of {@link AsyncHttpClientConfig}
- */
-public class AsyncHttpClientConfigBean extends AsyncHttpClientConfig {
-
- public AsyncHttpClientConfigBean() {
- configureExecutors();
- configureDefaults();
- configureFilters();
- }
-
- void configureFilters() {
- requestFilters = new LinkedListclient.prepareGet("http://foo.com/aResource").execute().get()
- * would not work for you, since a potentially large response body is about to
- * be GETted, but you need headers first, or you don't know yet (depending on
- * some logic, maybe coming from headers) where to save the body, or you just
- * want to leave body stream to some other component to consume it.
- *
- * All these above means that this AsyncHandler needs a bit of different
- * handling than "recommended" way. Some examples:
- *
- *
- * FileOutputStream fos = ...
- * BodyDeferringAsyncHandler bdah = new BodyDeferringAsyncHandler(fos);
- * // client executes async
- * Future<Response> fr = client.prepareGet("http://foo.com/aresource").execute(
- * bdah);
- * // main thread will block here until headers are available
- * Response response = bdah.getResponse();
- * // you can continue examine headers while actual body download happens
- * // in separate thread
- * // ...
- * // finally "join" the download
- * fr.get();
- *
- *
- *
- * PipedOutputStream pout = new PipedOutputStream();
- * BodyDeferringAsyncHandler bdah = new BodyDeferringAsyncHandler(pout);
- * // client executes async
- * Future<Response> fr = client.prepareGet("http://foo.com/aresource").execute(bdah);
- * // main thread will block here until headers are available
- * Response response = bdah.getResponse();
- * if (response.getStatusCode() == 200) {
- * InputStream pin = new BodyDeferringInputStream(fr,new PipedInputStream(pout));
- * // consume InputStream
- * ...
- * } else {
- * // handle unexpected response status code
- * ...
- * }
- *
- */
-public class BodyDeferringAsyncHandler implements AsyncHandlernull
- * in case of some errors.
- *
- * @return a {@link Response}
- * @throws InterruptedException
- */
- public Response getResponse() throws InterruptedException, IOException {
- // block here as long as headers arrive
- headersArrived.await();
-
- try {
- semaphore.acquire();
- if (throwable != null) {
- IOException ioe = new IOException(throwable.getMessage());
- ioe.initCause(throwable);
- throw ioe;
- } else {
- return response;
- }
- } finally {
- semaphore.release();
- }
- }
-
- // ==
-
- /**
- * A simple helper class that is used to perform automatic "join" for async
- * download and the error checking of the Future of the request.
- */
- public static class BodyDeferringInputStream extends FilterInputStream {
- private final Futurenull. See
- * {@link BodyDeferringAsyncHandler#getResponse()} method for details.
- *
- * @return a {@link Response}
- * @throws InterruptedException
- */
- public Response getAsapResponse() throws InterruptedException, IOException {
- return bdah.getResponse();
- }
-
- /**
- * Delegates to Future#get() method. Will block
- * as long as complete response arrives.
- *
- * @return a {@link Response}
- * @throws InterruptedException
- * @throws ExecutionException
- */
- public Response getLastResponse() throws InterruptedException, ExecutionException {
- return future.get();
- }
- }
-}
\ No newline at end of file
diff --git a/api/src/main/java/org/asynchttpclient/BoundRequestBuilder.java b/api/src/main/java/org/asynchttpclient/BoundRequestBuilder.java
deleted file mode 100644
index 028ce2a8c7..0000000000
--- a/api/src/main/java/org/asynchttpclient/BoundRequestBuilder.java
+++ /dev/null
@@ -1,133 +0,0 @@
-/*
- * Copyright (c) 2014 AsyncHttpClient Project. All rights reserved.
- *
- * This program is licensed to you under the Apache License Version 2.0,
- * and you may not use this file except in compliance with the Apache License Version 2.0.
- * You may obtain a copy of the Apache License Version 2.0 at http://www.apache.org/licenses/LICENSE-2.0.
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the Apache License Version 2.0 is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the Apache License Version 2.0 for the specific language governing permissions and limitations there under.
- */
-package org.asynchttpclient;
-
-import org.asynchttpclient.cookie.Cookie;
-import org.asynchttpclient.multipart.Part;
-
-import java.io.InputStream;
-import java.util.Collection;
-import java.util.List;
-import java.util.Map;
-
-public class BoundRequestBuilder extends RequestBuilderBaseAdds a listener and executor to the ListenableFuture. - * The listener will be {@linkplain java.util.concurrent.Executor#execute(Runnable) passed - * to the executor} for execution when the {@code Future}'s computation is - * {@linkplain Future#isDone() complete}. - *
- *There is no guaranteed ordering of execution of listeners, they may get
- * called in the order they were added and they may get called out of order,
- * but any listener added through this method is guaranteed to be called once
- * the computation is complete.
- *
- * @param listener the listener to run when the computation is complete.
- * @param exec the executor to run the listener in.
- * @return this Future
- * @throws NullPointerException if the executor or listener was null.
- * @throws java.util.concurrent.RejectedExecutionException
- * if we tried to execute the listener
- * immediately but the executor rejected it.
- */
- ListenableFuture
- */
-public interface Request {
-
- /**
- * Return the request's method name (GET, POST, etc.)
- *
- * @return the request's method name (GET, POST, etc.)
- */
- String getMethod();
-
- Uri getUri();
-
- String getUrl();
-
- /**
- * Return the InetAddress to override
- *
- * @return the InetAddress
- */
- InetAddress getInetAddress();
-
- InetAddress getLocalAddress();
-
- /**
- * Return the current set of Headers.
- *
- * @return a {@link FluentCaseInsensitiveStringsMap} contains headers.
- */
- FluentCaseInsensitiveStringsMap getHeaders();
-
- /**
- * Return Coookie.
- *
- * @return an unmodifiable Collection of Cookies
- */
- Collection
- * Request r = new RequestBuilder().setUrl("url")
- * .setRealm((new Realm.RealmBuilder()).setPrincipal(user)
- * .setPassword(admin)
- * .setRealmName("MyRealm")
- * .setScheme(Realm.AuthScheme.DIGEST).build());
- *
- * or
- *
- * SimpleAsyncHttpClient client = new SimpleAsyncHttpClient.Builder()
- * .setIdleConnectionInPoolTimeout(100)
- * .setMaximumConnectionsTotal(50)
- * .setRequestTimeout(5 * 60 * 1000)
- * .setUrl(getTargetUrl())
- * .setHeader("Content-Type", "text/html").build();
- *
- * StringBuilder s = new StringBuilder();
- * Future
- */
-public class SimpleAsyncHttpClient implements Closeable {
-
- private final AsyncHttpClientConfig config;
- private final RequestBuilder requestBuilder;
- private AsyncHttpClient asyncHttpClient;
- private final ThrowableHandler defaultThrowableHandler;
- private final boolean resumeEnabled;
- private final ErrorDocumentBehaviour errorDocumentBehaviour;
- private final SimpleAHCTransferListener listener;
- private final boolean derived;
- private final String providerClass;
-
- private SimpleAsyncHttpClient(AsyncHttpClientConfig config, RequestBuilder requestBuilder, ThrowableHandler defaultThrowableHandler,
- ErrorDocumentBehaviour errorDocumentBehaviour, boolean resumeEnabled, AsyncHttpClient ahc, SimpleAHCTransferListener listener,
- String providerClass) {
- this.config = config;
- this.requestBuilder = requestBuilder;
- this.defaultThrowableHandler = defaultThrowableHandler;
- this.resumeEnabled = resumeEnabled;
- this.errorDocumentBehaviour = errorDocumentBehaviour;
- this.asyncHttpClient = ahc;
- this.listener = listener;
- this.providerClass = providerClass;
-
- this.derived = ahc != null;
- }
-
- public Future
- * public void ByteArrayOutputStreamBodyConsumerTest() throws Throwable {
- *
- * SimpleAsyncHttpClient client = new SimpleAsyncHttpClient.Builder()
- * .setUrl(getTargetUrl())
- * .build();
- *
- * ByteArrayOutputStream o = new ByteArrayOutputStream(10);
- * Future