org.springframework.http.server.reactive

Class AbstractListenerServerHttpResponse

    • Constructor Detail

      • AbstractListenerServerHttpResponse

        public AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory)
    • Method Detail

      • writeAndFlushWithInternal

        protected final reactor.core.publisher.Mono<java.lang.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>,java.lang.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).