org.springframework.http.client

Class AbstractAsyncClientHttpRequest

java.lang.Object

org.springframework.http.client.AbstractAsyncClientHttpRequest

All Implemented Interfaces:

AsyncClientHttpRequest, HttpMessage, HttpOutputMessage, HttpRequest

Direct Known Subclasses:

AbstractBufferingAsyncClientHttpRequest, Netty4ClientHttpRequest, SimpleStreamingAsyncClientHttpRequest

abstract class AbstractAsyncClientHttpRequest
extends java.lang.Object
implements AsyncClientHttpRequest

Abstract base for AsyncClientHttpRequest that makes sure that headers and body are not written multiple times.

Since:

4.0

Author:

Arjen Poutsma

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	executed
private HttpHeaders	headers

Constructor Summary

Constructors

Constructor and Description
AbstractAsyncClientHttpRequest()

Method Summary

Modifier and Type	Method and Description
protected void	assertNotExecuted() Asserts that this request has not been executed yet.
ListenableFuture<ClientHttpResponse>	executeAsync() Execute this request asynchronously, resulting in a Future handle.
protected abstract ListenableFuture<ClientHttpResponse>	executeInternal(HttpHeaders headers) Abstract template method that writes the given headers and content to the HTTP request.
java.io.OutputStream	getBody() Return the body of the message as an output stream.
protected abstract java.io.OutputStream	getBodyInternal(HttpHeaders headers) Abstract template method that returns the body.
HttpHeaders	getHeaders() Return the headers of this message.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.http.HttpRequest

getMethod, getURI

Field Detail

headers

private final HttpHeaders headers

executed

private boolean executed

Constructor Detail

AbstractAsyncClientHttpRequest

AbstractAsyncClientHttpRequest()

Method Detail

getHeaders

public final HttpHeaders getHeaders()

Description copied from interface: HttpMessage

Return the headers of this message.

Specified by:

getHeaders in interface HttpMessage

Returns:

a corresponding HttpHeaders object (never null)

getBody

public final java.io.OutputStream getBody()
                                   throws java.io.IOException

Description copied from interface: HttpOutputMessage

Return the body of the message as an output stream.

Specified by:

getBody in interface HttpOutputMessage

Returns:

the output stream body (never null)

Throws:

java.io.IOException - in case of I/O Errors

executeAsync

public ListenableFuture<ClientHttpResponse> executeAsync()
                                                  throws java.io.IOException

Description copied from interface: AsyncClientHttpRequest

Execute this request asynchronously, resulting in a Future handle. ClientHttpResponse that can be read.

Specified by:

executeAsync in interface AsyncClientHttpRequest

Returns:

the future response result of the execution

Throws:

java.io.IOException - in case of I/O errors

assertNotExecuted

protected void assertNotExecuted()

Asserts that this request has not been executed yet.

Throws:

java.lang.IllegalStateException - if this request has been executed

getBodyInternal

protected abstract java.io.OutputStream getBodyInternal(HttpHeaders headers)
                                                 throws java.io.IOException

Abstract template method that returns the body.

Parameters:

headers - the HTTP headers

Returns:

the body output stream

Throws:

java.io.IOException

executeInternal

protected abstract ListenableFuture<ClientHttpResponse> executeInternal(HttpHeaders headers)
                                                                 throws java.io.IOException

Abstract template method that writes the given headers and content to the HTTP request.

Parameters:

headers - the HTTP headers

Returns:

the response object for the executed request

Throws:

java.io.IOException