Class MinimalHttpAsyncClient.InternalAsyncClientEndpoint
- java.lang.Object
-
- org.apache.hc.core5.http.nio.AsyncClientEndpoint
-
- org.apache.hc.client5.http.impl.async.MinimalHttpAsyncClient.InternalAsyncClientEndpoint
-
- Enclosing class:
- MinimalHttpAsyncClient
private class MinimalHttpAsyncClient.InternalAsyncClientEndpoint extends org.apache.hc.core5.http.nio.AsyncClientEndpoint
-
-
Field Summary
Fields Modifier and Type Field Description private AsyncConnectionEndpoint
connectionEndpoint
private java.util.concurrent.atomic.AtomicBoolean
released
-
Constructor Summary
Constructors Constructor Description InternalAsyncClientEndpoint(AsyncConnectionEndpoint connectionEndpoint)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
execute(org.apache.hc.core5.http.nio.AsyncClientExchangeHandler exchangeHandler, org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory, org.apache.hc.core5.http.protocol.HttpContext context)
boolean
isConnected()
(package private) boolean
isReleased()
void
releaseAndDiscard()
void
releaseAndReuse()
void
setSocketTimeout(org.apache.hc.core5.util.Timeout timeout)
-
-
-
Field Detail
-
connectionEndpoint
private final AsyncConnectionEndpoint connectionEndpoint
-
released
private final java.util.concurrent.atomic.AtomicBoolean released
-
-
Constructor Detail
-
InternalAsyncClientEndpoint
InternalAsyncClientEndpoint(AsyncConnectionEndpoint connectionEndpoint)
-
-
Method Detail
-
isReleased
boolean isReleased()
-
isConnected
public boolean isConnected()
- Specified by:
isConnected
in classorg.apache.hc.core5.http.nio.AsyncClientEndpoint
-
execute
public void execute(org.apache.hc.core5.http.nio.AsyncClientExchangeHandler exchangeHandler, org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory, org.apache.hc.core5.http.protocol.HttpContext context)
- Specified by:
execute
in classorg.apache.hc.core5.http.nio.AsyncClientEndpoint
-
setSocketTimeout
public void setSocketTimeout(org.apache.hc.core5.util.Timeout timeout)
-
releaseAndReuse
public void releaseAndReuse()
- Specified by:
releaseAndReuse
in classorg.apache.hc.core5.http.nio.AsyncClientEndpoint
-
releaseAndDiscard
public void releaseAndDiscard()
- Specified by:
releaseAndDiscard
in classorg.apache.hc.core5.http.nio.AsyncClientEndpoint
-
-