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

Direct Known Subclasses:

ServletServerHttpResponse, UndertowServerHttpResponse

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

Modifier and Type	Field and Description
private java.util.concurrent.atomic.AtomicBoolean	writeCalled

Constructor Summary

Constructors

Constructor and Description
AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory)

Method Summary

Modifier and Type	Method and Description
protected abstract <any>	createBodyFlushProcessor() Abstract template method to create a Processor<Publisher<DataBuffer>, Void> that will write the response body with flushes to the underlying output.
protected <any>	writeAndFlushWithInternal(<any> body) Implement this method to write to the underlying the response, and flush after each Publisher<DataBuffer>.
protected <any>	writeWithInternal(<any> body) Implement this method to write to the underlying the response.

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

applyCookies, applyHeaders, applyStatusCode, beforeCommit, bufferFactory, doCommit, doCommit, encodeUrl, getCookies, getHeaders, getStatusCode, isCommitted, registerUrlEncoder, setComplete, setStatusCode, writeAndFlushWith, writeWith

Methods inherited from class java.lang.Object

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

Field Detail

writeCalled

private final java.util.concurrent.atomic.AtomicBoolean writeCalled

Constructor Detail

AbstractListenerServerHttpResponse

public AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory)

Method Detail

writeWithInternal

protected final <any> writeWithInternal(<any> body)

Description copied from class: AbstractServerHttpResponse

Implement this method to write to the underlying the response.

Specified by:

writeWithInternal in class AbstractServerHttpResponse

Parameters:

body - the publisher to write with

writeAndFlushWithInternal

protected final <any> writeAndFlushWithInternal(<any> body)

Description copied from class: AbstractServerHttpResponse

Implement this method to 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 <any> 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).