public abstract class AbstractListenerServerHttpResponse extends AbstractServerHttpResponse
| Constructor and Description |
|---|
AbstractListenerServerHttpResponse(DataBufferFactory bufferFactory) |
AbstractListenerServerHttpResponse(DataBufferFactory bufferFactory,
HttpHeaders headers) |
| 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.
|
addCookie, applyCookies, applyHeaders, applyStatusCode, beforeCommit, bufferFactory, doCommit, doCommit, getCookies, getHeaders, getNativeResponse, getRawStatusCode, getStatusCode, getStatusCodeValue, isCommitted, setComplete, setRawStatusCode, setStatusCode, setStatusCodeValue, touchDataBuffer, writeAndFlushWith, writeWithpublic AbstractListenerServerHttpResponse(DataBufferFactory bufferFactory)
public AbstractListenerServerHttpResponse(DataBufferFactory bufferFactory, HttpHeaders headers)
protected final reactor.core.publisher.Mono<Void> writeWithInternal(org.reactivestreams.Publisher<? extends DataBuffer> body)
AbstractServerHttpResponsewriteWithInternal in class AbstractServerHttpResponsebody - the publisher to write withprotected final reactor.core.publisher.Mono<Void> writeAndFlushWithInternal(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> body)
AbstractServerHttpResponsePublisher<DataBuffer>.writeAndFlushWithInternal in class AbstractServerHttpResponsebody - the publisher to write and flush withprotected abstract org.reactivestreams.Processor<? super org.reactivestreams.Publisher<? extends DataBuffer>,Void> createBodyFlushProcessor()
Processor<Publisher<DataBuffer>, Void>
that will write the response body with flushes to the underlying output. Called from
writeAndFlushWithInternal(Publisher).