org.springframework.http

Interface ReactiveHttpOutputMessage

All Superinterfaces:

HttpMessage

All Known Subinterfaces:

ClientHttpRequest, ServerHttpResponse, ZeroCopyHttpOutputMessage

All Known Implementing Classes:

AbstractClientHttpRequest, AbstractListenerServerHttpResponse, AbstractServerHttpResponse, MockServerHttpResponse, ReactorClientHttpRequest, ReactorServerHttpResponse, RxNettyServerHttpResponse, ServerHttpResponseDecorator, ServletServerHttpResponse, UndertowServerHttpResponse

public interface ReactiveHttpOutputMessage
extends HttpMessage

A "reactive" HTTP output message that accepts output as a Publisher.

Typically implemented by an HTTP request on the client-side or a response on the server-side.

Since:

5.0

Author:

Arjen Poutsma, Sebastien Deleuze

Method Summary

Modifier and Type	Method and Description
void	beforeCommit(java.util.function.Supplier<? extends <any>> action) Register an action to be applied just before the message is committed.
DataBufferFactory	bufferFactory() Return a DataBufferFactory that can be used for creating the body.
<any>	setComplete() Indicate that message handling is complete, allowing for any cleanup or end-of-processing tasks to be performed such as applying header changes made via HttpMessage.getHeaders() to the underlying HTTP message (if not applied already).
<any>	writeAndFlushWith(<any> body) Use the given Publisher of Publishers to write the body of the message to the underlying HTTP layer, flushing after each Publisher<DataBuffer>.
<any>	writeWith(<any> body) Use the given Publisher to write the body of the message to the underlying HTTP layer.

Methods inherited from interface org.springframework.http.HttpMessage

getHeaders

Method Detail

bufferFactory

DataBufferFactory bufferFactory()

Return a DataBufferFactory that can be used for creating the body.

Returns:

a buffer factory

See Also:

#writeWith(Publisher)

beforeCommit

void beforeCommit(java.util.function.Supplier<? extends <any>> action)

Register an action to be applied just before the message is committed.

Parameters:

action - the action

writeWith

<any> writeWith(<any> body)

Use the given Publisher to write the body of the message to the underlying HTTP layer.

Parameters:

body - the body content publisher

Returns:

a Mono that indicates completion or error

writeAndFlushWith

<any> writeAndFlushWith(<any> body)

Use the given Publisher of Publishers to write the body of the message to the underlying HTTP layer, flushing after each Publisher<DataBuffer>.

Parameters:

body - the body content publisher

Returns:

a Mono that indicates completion or error

setComplete

<any> setComplete()

Indicate that message handling is complete, allowing for any cleanup or end-of-processing tasks to be performed such as applying header changes made via HttpMessage.getHeaders() to the underlying HTTP message (if not applied already).

This method should be automatically invoked at the end of message processing so typically applications should not have to invoke it. If invoked multiple times it should have no side effects.

Returns:

a Mono that indicates completion or error