com.screenscraper.http

Class AsyncScrapingHttpClient2.SharedAsyncHttpClient

java.lang.Object

com.screenscraper.http.util.SharedHttpClientBase

com.screenscraper.http.AsyncScrapingHttpClient2.SharedAsyncHttpClient

All Implemented Interfaces:

SharedHttpClient, java.io.Closeable, java.lang.AutoCloseable, org.asynchttpclient.AsyncHttpClient

Enclosing class:

AsyncScrapingHttpClient2

public static class AsyncScrapingHttpClient2.SharedAsyncHttpClient
extends SharedHttpClientBase
implements org.asynchttpclient.AsyncHttpClient

Class to wrap an async client so it can be shared (save on resources) but still closed like normal

Field Summary

Fields inherited from interface com.screenscraper.http.util.SharedHttpClient

SHUTDOWN_USE_COUNT

Constructor Summary

Constructors

Constructor and Description
SharedAsyncHttpClient(CleanableReference<org.asynchttpclient.AsyncHttpClient> wrappedClient)

Method Summary

Modifier and Type	Method and Description
protected void	closeUnderlyingResources() Method called to close any resources when no more references are held to this object.
org.asynchttpclient.ListenableFuture<org.asynchttpclient.Response>	executeRequest(org.asynchttpclient.Request request)
<T> org.asynchttpclient.ListenableFuture<T>	executeRequest(org.asynchttpclient.Request request, org.asynchttpclient.AsyncHandler<T> asyncHandler)
org.asynchttpclient.ListenableFuture<org.asynchttpclient.Response>	executeRequest(org.asynchttpclient.RequestBuilder requestBuilder)
<T> org.asynchttpclient.ListenableFuture<T>	executeRequest(org.asynchttpclient.RequestBuilder requestBuilder, org.asynchttpclient.AsyncHandler<T> asyncHandler)
void	flushChannelPoolPartitions(java.util.function.Predicate<java.lang.Object> predicate)
org.asynchttpclient.ClientStats	getClientStats()
org.asynchttpclient.AsyncHttpClientConfig	getConfig()
org.asynchttpclient.BoundRequestBuilder	prepare(java.lang.String s, java.lang.String s1)
org.asynchttpclient.BoundRequestBuilder	prepareConnect(java.lang.String s)
org.asynchttpclient.BoundRequestBuilder	prepareDelete(java.lang.String s)
org.asynchttpclient.BoundRequestBuilder	prepareGet(java.lang.String s)
org.asynchttpclient.BoundRequestBuilder	prepareHead(java.lang.String s)
org.asynchttpclient.BoundRequestBuilder	prepareOptions(java.lang.String s)
org.asynchttpclient.BoundRequestBuilder	preparePatch(java.lang.String s)
org.asynchttpclient.BoundRequestBuilder	preparePost(java.lang.String s)
org.asynchttpclient.BoundRequestBuilder	preparePut(java.lang.String s)
org.asynchttpclient.BoundRequestBuilder	prepareRequest(org.asynchttpclient.Request request)
org.asynchttpclient.BoundRequestBuilder	prepareRequest(org.asynchttpclient.RequestBuilder requestBuilder)
org.asynchttpclient.BoundRequestBuilder	prepareTrace(java.lang.String s)
void	registerRemovalOnClose(HttpClientKey key)
org.asynchttpclient.AsyncHttpClient	setSignatureCalculator(org.asynchttpclient.SignatureCalculator signatureCalculator)

Methods inherited from class com.screenscraper.http.util.SharedHttpClientBase

addUse, close, getCurrentUsers, getOpenCount, isClosed, registerUser, removeUser, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.asynchttpclient.AsyncHttpClient

isClosed

Methods inherited from interface java.io.Closeable

close

Constructor Detail

SharedAsyncHttpClient

public SharedAsyncHttpClient(@NotNull
                             CleanableReference<org.asynchttpclient.AsyncHttpClient> wrappedClient)

Method Detail

registerRemovalOnClose

public void registerRemovalOnClose(@NotNull
                                   HttpClientKey key)

setSignatureCalculator

public org.asynchttpclient.AsyncHttpClient setSignatureCalculator(org.asynchttpclient.SignatureCalculator signatureCalculator)

Specified by:

setSignatureCalculator in interface org.asynchttpclient.AsyncHttpClient

prepareGet

public org.asynchttpclient.BoundRequestBuilder prepareGet(java.lang.String s)

Specified by:

prepareGet in interface org.asynchttpclient.AsyncHttpClient

prepareConnect

public org.asynchttpclient.BoundRequestBuilder prepareConnect(java.lang.String s)

Specified by:

prepareConnect in interface org.asynchttpclient.AsyncHttpClient

prepareOptions

public org.asynchttpclient.BoundRequestBuilder prepareOptions(java.lang.String s)

Specified by:

prepareOptions in interface org.asynchttpclient.AsyncHttpClient

prepareHead

public org.asynchttpclient.BoundRequestBuilder prepareHead(java.lang.String s)

Specified by:

prepareHead in interface org.asynchttpclient.AsyncHttpClient

preparePost

public org.asynchttpclient.BoundRequestBuilder preparePost(java.lang.String s)

Specified by:

preparePost in interface org.asynchttpclient.AsyncHttpClient

preparePut

public org.asynchttpclient.BoundRequestBuilder preparePut(java.lang.String s)

Specified by:

preparePut in interface org.asynchttpclient.AsyncHttpClient

prepareDelete

public org.asynchttpclient.BoundRequestBuilder prepareDelete(java.lang.String s)

Specified by:

prepareDelete in interface org.asynchttpclient.AsyncHttpClient

preparePatch

public org.asynchttpclient.BoundRequestBuilder preparePatch(java.lang.String s)

Specified by:

preparePatch in interface org.asynchttpclient.AsyncHttpClient

prepareTrace

public org.asynchttpclient.BoundRequestBuilder prepareTrace(java.lang.String s)

Specified by:

prepareTrace in interface org.asynchttpclient.AsyncHttpClient

prepareRequest

public org.asynchttpclient.BoundRequestBuilder prepareRequest(org.asynchttpclient.Request request)

Specified by:

prepareRequest in interface org.asynchttpclient.AsyncHttpClient

prepareRequest

public org.asynchttpclient.BoundRequestBuilder prepareRequest(org.asynchttpclient.RequestBuilder requestBuilder)

Specified by:

prepareRequest in interface org.asynchttpclient.AsyncHttpClient

executeRequest

public <T> org.asynchttpclient.ListenableFuture<T> executeRequest(org.asynchttpclient.Request request,
                                                                  org.asynchttpclient.AsyncHandler<T> asyncHandler)

Specified by:

executeRequest in interface org.asynchttpclient.AsyncHttpClient

executeRequest

public <T> org.asynchttpclient.ListenableFuture<T> executeRequest(org.asynchttpclient.RequestBuilder requestBuilder,
                                                                  org.asynchttpclient.AsyncHandler<T> asyncHandler)

Specified by:

executeRequest in interface org.asynchttpclient.AsyncHttpClient

executeRequest

public org.asynchttpclient.ListenableFuture<org.asynchttpclient.Response> executeRequest(org.asynchttpclient.Request request)

Specified by:

executeRequest in interface org.asynchttpclient.AsyncHttpClient

executeRequest

public org.asynchttpclient.ListenableFuture<org.asynchttpclient.Response> executeRequest(org.asynchttpclient.RequestBuilder requestBuilder)

Specified by:

executeRequest in interface org.asynchttpclient.AsyncHttpClient

flushChannelPoolPartitions

public void flushChannelPoolPartitions(java.util.function.Predicate<java.lang.Object> predicate)

Specified by:

flushChannelPoolPartitions in interface org.asynchttpclient.AsyncHttpClient

prepare

public org.asynchttpclient.BoundRequestBuilder prepare(java.lang.String s,
                                                       java.lang.String s1)

Specified by:

prepare in interface org.asynchttpclient.AsyncHttpClient

getClientStats

public org.asynchttpclient.ClientStats getClientStats()

Specified by:

getClientStats in interface org.asynchttpclient.AsyncHttpClient

getConfig

public org.asynchttpclient.AsyncHttpClientConfig getConfig()

Specified by:

getConfig in interface org.asynchttpclient.AsyncHttpClient

closeUnderlyingResources

protected void closeUnderlyingResources()
                                 throws java.io.IOException

Description copied from class: SharedHttpClientBase

Method called to close any resources when no more references are held to this object. This method should only be called once during the lifetime of the object

Specified by:

closeUnderlyingResources in class SharedHttpClientBase

Throws:

java.io.IOException - On error closing the resources