Top Fields Constructors Methods
io.undertow.client.http

pack-priv Class HttpClientExchange

extends AbstractAttachable
implements ClientExchange
Class Inheritance
All Implemented Interfaces
io.undertow.client.ClientExchange, io.undertow.util.Attachable
Imports
io.undertow.channels.DetachableStreamSinkChannel, .DetachableStreamSourceChannel, io.undertow.client.ClientCallback, .ClientConnection, .ClientExchange, .ClientRequest, .ClientResponse, .ContinueNotification, .PushCallback, io.undertow.util.AbstractAttachable, .Headers, org.jboss.logging.Logger, org.xnio.channels.StreamSinkChannel, .StreamSourceChannel, java.io.IOException
Author
Stuart Douglas

Field Summary

Modifier and TypeField and Description
private final HttpClientConnection
clientConnection

private ContinueNotification
continueNotification

private ClientResponse
continueResponse

private IOException
failedReason

private static final Logger
log

private ClientCallback<ClientExchange>
readyCallback

private final ClientRequest
request

private static final int
REQUEST_TERMINATED

private HttpRequestConduit
requestConduit

private final boolean
requiresContinue

private ClientResponse
response

private static final int
RESPONSE_TERMINATED

private ClientCallback<ClientExchange>
responseCallback

private int
state

Constructor Summary

AccessConstructor and Description
pack-priv
HttpClientExchange(ClientCallback<ClientExchange> readyCallback, ClientRequest request, HttpClientConnection clientConnection)

Method Summary

Modifier and TypeMethod and Description
public ClientConnection
getConnection()

Implements io.undertow.client.ClientExchange.getConnection.

public ClientResponse
getContinueResponse()

Implements io.undertow.client.ClientExchange.getContinueResponse.

public ClientRequest
getRequest()

Implements io.undertow.client.ClientExchange.getRequest.

public StreamSinkChannel
getRequestChannel()

Implements io.undertow.client.ClientExchange.getRequestChannel.

Returns the request channel that can be used to send data to the server.

public ClientResponse
getResponse()

Implements io.undertow.client.ClientExchange.getResponse.

pack-priv ClientCallback<ClientExchange>
getResponseCallback()

public StreamSourceChannel
getResponseChannel()

Implements io.undertow.client.ClientExchange.getResponseChannel.

Returns the response channel that can be used to read data from the target server.

pack-priv void
invokeReadReadyCallback()

pack-priv boolean
isRequestDataSent()

public boolean
isRequiresContinue()

public void
setContinueHandler(ContinueNotification continueHandler)

Implements io.undertow.client.ClientExchange.setContinueHandler.

pack-priv void
setContinueResponse(ClientResponse response)

pack-priv void
setFailed(IOException e)

public void
setPushHandler(PushCallback pushCallback)

Implements io.undertow.client.ClientExchange.setPushHandler.

public void
setRequestConduit(HttpRequestConduit requestConduit)

pack-priv void
setResponse(ClientResponse response)

public void
setResponseListener(ClientCallback<ClientExchange> listener)

Implements io.undertow.client.ClientExchange.setResponseListener.

pack-priv void
terminateRequest()

pack-priv void
terminateResponse()

Inherited from io.undertow.util.AbstractAttachable:
addToAttachmentListcreateAttachmentMapgetAttachmentgetAttachmentListputAttachmentremoveAttachment

Field Detail

clientConnectionback to summary
private final HttpClientConnection clientConnection
continueNotificationback to summary
private ContinueNotification continueNotification
continueResponseback to summary
private ClientResponse continueResponse
failedReasonback to summary
private IOException failedReason
logback to summary
private static final Logger log
readyCallbackback to summary
private ClientCallback<ClientExchange> readyCallback
requestback to summary
private final ClientRequest request
REQUEST_TERMINATEDback to summary
private static final int REQUEST_TERMINATED
requestConduitback to summary
private HttpRequestConduit requestConduit
requiresContinueback to summary
private final boolean requiresContinue
responseback to summary
private ClientResponse response
RESPONSE_TERMINATEDback to summary
private static final int RESPONSE_TERMINATED
responseCallbackback to summary
private ClientCallback<ClientExchange> responseCallback
stateback to summary
private int state

Constructor Detail

HttpClientExchangeback to summary
pack-priv HttpClientExchange(ClientCallback<ClientExchange> readyCallback, ClientRequest request, HttpClientConnection clientConnection)

Method Detail

getConnectionback to summary
public ClientConnection getConnection()

Implements io.undertow.client.ClientExchange.getConnection.

Returns:ClientConnection

Doc from io.undertow.client.ClientExchange.getConnection.

The underlying connection

Annotations
@Override
getContinueResponseback to summary
public ClientResponse getContinueResponse()

Implements io.undertow.client.ClientExchange.getContinueResponse.

Returns:ClientResponse

Doc from io.undertow.client.ClientExchange.getContinueResponse.

the result of a HTTP 100-continue response

Annotations
@Override
getRequestback to summary
public ClientRequest getRequest()

Implements io.undertow.client.ClientExchange.getRequest.

Annotations
@Override
getRequestChannelback to summary
public StreamSinkChannel getRequestChannel()

Implements io.undertow.client.ClientExchange.getRequestChannel.

Doc from io.undertow.client.ClientExchange.getRequestChannel.

Returns the request channel that can be used to send data to the server.

Returns:StreamSinkChannel

The request channel

Annotations
@Override
getResponseback to summary
public ClientResponse getResponse()

Implements io.undertow.client.ClientExchange.getResponse.

Returns:ClientResponse

Doc from io.undertow.client.ClientExchange.getResponse.

The client response, or null if it has not been received yet

Annotations
@Override
getResponseCallbackback to summary
pack-priv ClientCallback<ClientExchange> getResponseCallback()
getResponseChannelback to summary
public StreamSourceChannel getResponseChannel()

Implements io.undertow.client.ClientExchange.getResponseChannel.

Doc from io.undertow.client.ClientExchange.getResponseChannel.

Returns the response channel that can be used to read data from the target server.

Returns:StreamSourceChannel

The response channel

Annotations
@Override
invokeReadReadyCallbackback to summary
pack-priv void invokeReadReadyCallback()
isRequestDataSentback to summary
pack-priv boolean isRequestDataSent()
isRequiresContinueback to summary
public boolean isRequiresContinue()
setContinueHandlerback to summary
public void setContinueHandler(ContinueNotification continueHandler)

Implements io.undertow.client.ClientExchange.setContinueHandler.

Annotations
@Override
setContinueResponseback to summary
pack-priv void setContinueResponse(ClientResponse response)
setFailedback to summary
pack-priv void setFailed(IOException e)
setPushHandlerback to summary
public void setPushHandler(PushCallback pushCallback)

Implements io.undertow.client.ClientExchange.setPushHandler.

Annotations
@Override
setRequestConduitback to summary
public void setRequestConduit(HttpRequestConduit requestConduit)
setResponseback to summary
pack-priv void setResponse(ClientResponse response)
setResponseListenerback to summary
public void setResponseListener(ClientCallback<ClientExchange> listener)

Implements io.undertow.client.ClientExchange.setResponseListener.

Annotations
@Override
terminateRequestback to summary
pack-priv void terminateRequest()
terminateResponseback to summary
pack-priv void terminateResponse()