org.springframework.http.server.reactive

Class AbstractListenerServerHttpResponse

java.lang.Object

org.springframework.http.server.reactive.AbstractServerHttpResponse

org.springframework.http.server.reactive.AbstractListenerServerHttpResponse

All Implemented Interfaces:

HttpMessage, ReactiveHttpOutputMessage, ServerHttpResponse

public abstract class AbstractListenerServerHttpResponse
extends AbstractServerHttpResponse

Abstract base class for listener-based server responses, e.g. Servlet 3.1 and Undertow.

Since:

5.0

Author:

Arjen Poutsma

Field Summary

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

logger

Constructor Summary

Constructors

Constructor and Description
AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory)
AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory, HttpHeaders headers)

Method Summary

Modifier and Type	Method and Description
protected abstract org.reactivestreams.Processor<? super org.reactivestreams.Publisher<? extends DataBuffer>,Void>	createBodyFlushProcessor() Abstract template method to create a Processor<Publisher<DataBuffer>, Void> that will write the response body with flushes to the underlying output.
protected reactor.core.publisher.Mono<Void>	writeAndFlushWithInternal(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> body) Write to the underlying the response, and flush after each Publisher<DataBuffer>.
protected reactor.core.publisher.Mono<Void>	writeWithInternal(org.reactivestreams.Publisher<? extends DataBuffer> body) Write to the underlying the response.

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

addCookie, applyCookies, applyHeaders, applyStatusCode, beforeCommit, bufferFactory, doCommit, doCommit, getCookies, getHeaders, getNativeResponse, getStatusCode, getStatusCodeValue, isCommitted, setComplete, setStatusCode, setStatusCodeValue, writeAndFlushWith, writeWith

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractListenerServerHttpResponse

public AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory)

AbstractListenerServerHttpResponse

public AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory,
                                          HttpHeaders headers)

Method Detail

writeWithInternal

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

Description copied from class: AbstractServerHttpResponse

Write to the underlying the response.

Specified by:

writeWithInternal in class AbstractServerHttpResponse

Parameters:

body - the publisher to write with

writeAndFlushWithInternal

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

Description copied from class: AbstractServerHttpResponse

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

Specified by:

writeAndFlushWithInternal in class AbstractServerHttpResponse

Parameters:

body - the publisher to write and flush with

createBodyFlushProcessor

protected abstract org.reactivestreams.Processor<? super org.reactivestreams.Publisher<? extends DataBuffer>,Void> createBodyFlushProcessor()

Abstract template method to create a Processor<Publisher<DataBuffer>, Void> that will write the response body with flushes to the underlying output. Called from writeAndFlushWithInternal(Publisher).