org.springframework.http.client

Class SimpleStreamingAsyncClientHttpRequest

java.lang.Object

org.springframework.http.client.AbstractAsyncClientHttpRequest

org.springframework.http.client.SimpleStreamingAsyncClientHttpRequest

All Implemented Interfaces:

AsyncClientHttpRequest, HttpMessage, HttpOutputMessage, HttpRequest

final class SimpleStreamingAsyncClientHttpRequest
extends AbstractAsyncClientHttpRequest

ClientHttpRequest implementation that uses standard Java facilities to execute streaming requests. Created via the SimpleClientHttpRequestFactory.

Since:

3.0

Author:

Arjen Poutsma

See Also:

SimpleClientHttpRequestFactory.createRequest(java.net.URI, org.springframework.http.HttpMethod)

Field Summary

Fields

Modifier and Type	Field and Description
private java.io.OutputStream	body
private int	chunkSize
private java.net.HttpURLConnection	connection
private boolean	outputStreaming
private AsyncListenableTaskExecutor	taskExecutor

Constructor Summary

Constructors

Constructor and Description
SimpleStreamingAsyncClientHttpRequest(java.net.HttpURLConnection connection, int chunkSize, boolean outputStreaming, AsyncListenableTaskExecutor taskExecutor)

Method Summary

Modifier and Type	Method and Description
protected ListenableFuture<ClientHttpResponse>	executeInternal(HttpHeaders headers) Abstract template method that writes the given headers and content to the HTTP request.
protected java.io.OutputStream	getBodyInternal(HttpHeaders headers) Abstract template method that returns the body.
HttpMethod	getMethod() Return the HTTP method of the request.
java.net.URI	getURI() Return the URI of the request.

Methods inherited from class org.springframework.http.client.AbstractAsyncClientHttpRequest

assertNotExecuted, executeAsync, getBody, getHeaders

Methods inherited from class java.lang.Object

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

Field Detail

connection

private final java.net.HttpURLConnection connection

chunkSize

private final int chunkSize

body

private java.io.OutputStream body

outputStreaming

private final boolean outputStreaming

taskExecutor

private final AsyncListenableTaskExecutor taskExecutor

Constructor Detail

SimpleStreamingAsyncClientHttpRequest

SimpleStreamingAsyncClientHttpRequest(java.net.HttpURLConnection connection,
                                      int chunkSize,
                                      boolean outputStreaming,
                                      AsyncListenableTaskExecutor taskExecutor)

Method Detail

getMethod

public HttpMethod getMethod()

Description copied from interface: HttpRequest

Return the HTTP method of the request.

Returns:

the HTTP method as an HttpMethod enum value, or null if not resolvable (e.g. in case of a non-standard HTTP method)

getURI

public java.net.URI getURI()

Description copied from interface: HttpRequest

Return the URI of the request.

Returns:

the URI of the request (never null)

getBodyInternal

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

Description copied from class: AbstractAsyncClientHttpRequest

Abstract template method that returns the body.

Specified by:

getBodyInternal in class AbstractAsyncClientHttpRequest

Parameters:

headers - the HTTP headers

Returns:

the body output stream

Throws:

java.io.IOException

executeInternal

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

Description copied from class: AbstractAsyncClientHttpRequest

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

Specified by:

executeInternal in class AbstractAsyncClientHttpRequest

Parameters:

headers - the HTTP headers

Returns:

the response object for the executed request

Throws:

java.io.IOException