Package org.springframework.http.server.reactive
@NullMarked
package org.springframework.http.server.reactive
Abstractions for reactive HTTP server support including a
ServerHttpRequest and
ServerHttpResponse along with an
HttpHandler for processing.
Also provides implementations adapting to different runtimes including Servlet containers and Netty + Reactor IO.
-
ClassDescriptionAbstract base class for
Publisherimplementations that bridge between event-listener read APIs and Reactive Streams.Abstract base class for listener-based server responses.An alternative toAbstractListenerWriteProcessorbut instead writing aPublisher<Publisher<T>>with flush boundaries enforces after the completion of each nested Publisher.Abstract base class forProcessorimplementations that bridge between event-listener write APIs and Reactive Streams.Common base class forServerHttpRequestimplementations.Base class forServerHttpResponseimplementations.Given a write function that accepts a sourcePublisher<T>to write with and returnsPublisher<Void>for the result, this operator helps to defer the invocation of the write function, until we know if the source publisher will begin publishing without an error.HttpHandlerdelegating requests to one of severalHttpHandler's based on simple, prefix-based mappings.Lowest level contract for reactive HTTP request handling that serves as a common denominator across different runtimes.Contract for applying a decorator to anHttpHandler.ServerHttpResponsedecorator for HTTP HEAD requests.AdaptHttpHandlerto the JettyHandlerabstraction.AdaptHttpHandlerto the Reactor Netty channel handling function.Represents a reactive server-side HTTP request.Builder for mutating an existingServerHttpRequest.Wraps anotherServerHttpRequestand delegates all methods to it.Represents a reactive server-side HTTP response.Wraps anotherServerHttpResponseand delegates all methods to it.AdaptHttpHandlerto anHttpServletusing Servlet Async support and Servlet non-blocking I/O.A holder for SSL session information.ServletHttpHandlerAdapterextension that uses Tomcat APIs for reading from the request and writing to the response withByteBuffer.