org.springframework.http.server.reactive

Class ReactorServerHttpResponse

java.lang.Object

org.springframework.http.server.reactive.AbstractServerHttpResponse

org.springframework.http.server.reactive.ReactorServerHttpResponse

All Implemented Interfaces:

HttpMessage, ReactiveHttpOutputMessage, ServerHttpResponse, ZeroCopyHttpOutputMessage

public class ReactorServerHttpResponse
extends AbstractServerHttpResponse
implements ZeroCopyHttpOutputMessage

Adapt ServerHttpResponse to the HttpServerResponse.

Since:

5.0

Author:

Stephane Maldini, Rossen Stoyanchev

Constructor Summary

Constructors

Constructor and Description
ReactorServerHttpResponse(reactor.ipc.netty.http.server.HttpServerResponse response, DataBufferFactory bufferFactory)

Method Summary

Modifier and Type	Method and Description
protected void	applyCookies() Add cookies from AbstractServerHttpResponse.getHeaders() to the underlying response.
protected void	applyHeaders() Apply header changes from AbstractServerHttpResponse.getHeaders() to the underlying response.
protected void	applyStatusCode() Write the status code to the underlying response.
reactor.ipc.netty.http.server.HttpServerResponse	getReactorResponse()
protected reactor.core.publisher.Mono<Void>	writeAndFlushWithInternal(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> publisher) Write to the underlying the response, and flush after each Publisher<DataBuffer>.
reactor.core.publisher.Mono<Void>	writeWith(File file, long position, long count) Use the given File to write the body of the message to the underlying HTTP layer.
protected reactor.core.publisher.Mono<Void>	writeWithInternal(org.reactivestreams.Publisher<? extends DataBuffer> publisher) Write to the underlying the response.

Methods inherited from class org.springframework.http.server.reactive.AbstractServerHttpResponse

addCookie, beforeCommit, bufferFactory, doCommit, doCommit, getCookies, getHeaders, getStatusCode, isCommitted, setComplete, setStatusCode, writeAndFlushWith, writeWith

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.ReactiveHttpOutputMessage

beforeCommit, bufferFactory, isCommitted, setComplete, writeAndFlushWith, writeWith

Methods inherited from interface org.springframework.http.HttpMessage

getHeaders

Constructor Detail

ReactorServerHttpResponse

public ReactorServerHttpResponse(reactor.ipc.netty.http.server.HttpServerResponse response,
                                 DataBufferFactory bufferFactory)

Method Detail

getReactorResponse

public reactor.ipc.netty.http.server.HttpServerResponse getReactorResponse()

applyStatusCode

protected void applyStatusCode()

Description copied from class: AbstractServerHttpResponse

Write the status code to the underlying response. This method is called once only.

Specified by:

applyStatusCode in class AbstractServerHttpResponse

writeWithInternal

protected reactor.core.publisher.Mono<Void> writeWithInternal(org.reactivestreams.Publisher<? extends DataBuffer> publisher)

Description copied from class: AbstractServerHttpResponse

Write to the underlying the response.

Specified by:

writeWithInternal in class AbstractServerHttpResponse

Parameters:

publisher - the publisher to write with

writeAndFlushWithInternal

protected reactor.core.publisher.Mono<Void> writeAndFlushWithInternal(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> publisher)

Description copied from class: AbstractServerHttpResponse

Write to the underlying the response, and flush after each Publisher<DataBuffer>.

Specified by:

writeAndFlushWithInternal in class AbstractServerHttpResponse

Parameters:

publisher - the publisher to write and flush with

applyHeaders

protected void applyHeaders()

Description copied from class: AbstractServerHttpResponse

Apply header changes from AbstractServerHttpResponse.getHeaders() to the underlying response. This method is called once only.

Specified by:

applyHeaders in class AbstractServerHttpResponse

applyCookies

protected void applyCookies()

Description copied from class: AbstractServerHttpResponse

Add cookies from AbstractServerHttpResponse.getHeaders() to the underlying response. This method is called once only.

Specified by:

applyCookies in class AbstractServerHttpResponse

writeWith

public reactor.core.publisher.Mono<Void> writeWith(File file,
                                                   long position,
                                                   long count)

Description copied from interface: ZeroCopyHttpOutputMessage

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

Specified by:

writeWith in interface ZeroCopyHttpOutputMessage

Parameters:

file - the file to transfer

position - the position within the file from which the transfer is to begin

count - the number of bytes to be transferred

Returns:

a publisher that indicates completion or error.