public abstract class AbstractListenerServerHttpResponse extends AbstractServerHttpResponse
| Constructor and Description |
|---|
AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract org.reactivestreams.Processor<org.reactivestreams.Publisher<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<org.reactivestreams.Publisher<DataBuffer>> body)
Implement this method to write to the underlying the response, and flush after
each
Publisher<DataBuffer>. |
protected reactor.core.publisher.Mono<Void> |
writeWithInternal(org.reactivestreams.Publisher<DataBuffer> body)
Implement this method to write to the underlying the response.
|
applyBeforeCommit, beforeCommit, bufferFactory, getCookies, getHeaders, getStatusCode, setComplete, setStatusCode, writeAndFlushWith, writeCookies, writeHeaders, writeStatusCode, writeWithpublic AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory)
protected final reactor.core.publisher.Mono<Void> writeWithInternal(org.reactivestreams.Publisher<DataBuffer> body)
AbstractServerHttpResponsewriteWithInternal in class AbstractServerHttpResponsebody - the publisher to write withprotected final reactor.core.publisher.Mono<Void> writeAndFlushWithInternal(org.reactivestreams.Publisher<org.reactivestreams.Publisher<DataBuffer>> body)
AbstractServerHttpResponsePublisher<DataBuffer>.writeAndFlushWithInternal in class AbstractServerHttpResponsebody - the publisher to write and flush withprotected abstract org.reactivestreams.Processor<org.reactivestreams.Publisher<DataBuffer>,Void> createBodyFlushProcessor()
Processor<Publisher<DataBuffer>, Void>
that will write the response body with flushes to the underlying output. Called from
writeAndFlushWithInternal(Publisher).