Package org.apache.hc.core5.testing.nio
Class ClientSessionEndpoint
java.lang.Object
org.apache.hc.core5.testing.nio.ClientSessionEndpoint
- All Implemented Interfaces:
Closeable
,AutoCloseable
,ModalCloseable
@Contract(threading=SAFE_CONDITIONAL)
public final class ClientSessionEndpoint
extends Object
implements ModalCloseable
Client endpoint that can be used to initiate HTTP message exchanges.
- Since:
- 5.0
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
void
Closes this process or endpoint and releases any system resources associated with it.void
execute
(AsyncClientExchangeHandler exchangeHandler, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, HttpContext context) void
execute
(AsyncClientExchangeHandler exchangeHandler, HttpContext context) <T> Future
<T> execute
(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, FutureCallback<T> callback) <T> Future
<T> execute
(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, HttpContext context, FutureCallback<T> callback) <T> Future
<T> execute
(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, HttpContext context, FutureCallback<T> callback) void
execute
(Command command, Command.Priority priority) boolean
isOpen()
toString()
-
Field Details
-
ioSession
-
closed
-
-
Constructor Details
-
ClientSessionEndpoint
-
-
Method Details
-
execute
-
execute
public void execute(AsyncClientExchangeHandler exchangeHandler, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, HttpContext context) -
execute
-
execute
public <T> Future<T> execute(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, HttpContext context, FutureCallback<T> callback) -
execute
public <T> Future<T> execute(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, HttpContext context, FutureCallback<T> callback) -
execute
public <T> Future<T> execute(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, FutureCallback<T> callback) -
isOpen
public boolean isOpen() -
close
Description copied from interface:ModalCloseable
Closes this process or endpoint and releases any system resources associated with it. If the endpoint or the process is already closed then invoking this method has no effect.- Specified by:
close
in interfaceModalCloseable
- Parameters:
closeMode
- How to close the receiver.
-
close
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Throws:
IOException
-
toString
-