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