Package | Description |
---|---|
org.springframework.http.client.reactive |
Abstractions for reactive HTTP client support including
ClientHttpRequest and
ClientHttpResponse as well as a
ClientHttpConnector . |
org.springframework.http.codec | |
org.springframework.http.codec.multipart |
Multipart support.
|
org.springframework.http.server.reactive |
Abstractions for reactive HTTP server support including a
ServerHttpRequest and
ServerHttpResponse along with an
HttpHandler for processing. |
org.springframework.mock.http.client.reactive |
Mock implementations of reactive HTTP client contracts.
|
org.springframework.mock.http.server.reactive |
Mock implementations of reactive HTTP server contracts.
|
org.springframework.test.web.reactive.server |
Support for testing Spring WebFlux server endpoints via
WebTestClient . |
org.springframework.web.reactive.function |
Provides a foundation for both the reactive client and server subpackages.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ClientHttpResponse
Represents a client-side reactive HTTP response.
|
Modifier and Type | Class and Description |
---|---|
class |
ClientHttpResponseDecorator
Wraps another
ClientHttpResponse and delegates all methods to it. |
Modifier and Type | Method and Description |
---|---|
protected Map<String,Object> |
ResourceHttpMessageReader.getReadHints(ResolvableType elementType,
ReactiveHttpInputMessage message) |
protected Map<String,Object> |
DecoderHttpMessageReader.getReadHints(ResolvableType elementType,
ReactiveHttpInputMessage message)
Get additional hints for decoding based on the input HTTP message.
|
reactor.core.publisher.Flux<Object> |
ServerSentEventHttpMessageReader.read(ResolvableType elementType,
ReactiveHttpInputMessage message,
Map<String,Object> hints) |
reactor.core.publisher.Flux<T> |
DecoderHttpMessageReader.read(ResolvableType elementType,
ReactiveHttpInputMessage message,
Map<String,Object> hints) |
reactor.core.publisher.Flux<T> |
HttpMessageReader.read(ResolvableType elementType,
ReactiveHttpInputMessage message,
Map<String,Object> hints)
Read from the input message and decode to a stream of objects.
|
reactor.core.publisher.Flux<MultiValueMap<String,String>> |
FormHttpMessageReader.read(ResolvableType elementType,
ReactiveHttpInputMessage message,
Map<String,Object> hints) |
reactor.core.publisher.Mono<Object> |
ServerSentEventHttpMessageReader.readMono(ResolvableType elementType,
ReactiveHttpInputMessage message,
Map<String,Object> hints) |
reactor.core.publisher.Mono<T> |
DecoderHttpMessageReader.readMono(ResolvableType elementType,
ReactiveHttpInputMessage message,
Map<String,Object> hints) |
reactor.core.publisher.Mono<T> |
HttpMessageReader.readMono(ResolvableType elementType,
ReactiveHttpInputMessage message,
Map<String,Object> hints)
Read from the input message and decode to a single object.
|
reactor.core.publisher.Mono<MultiValueMap<String,String>> |
FormHttpMessageReader.readMono(ResolvableType elementType,
ReactiveHttpInputMessage message,
Map<String,Object> hints) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<Part> |
SynchronossPartHttpMessageReader.read(ResolvableType elementType,
ReactiveHttpInputMessage message,
Map<String,Object> hints) |
reactor.core.publisher.Flux<MultiValueMap<String,Part>> |
MultipartHttpMessageReader.read(ResolvableType elementType,
ReactiveHttpInputMessage message,
Map<String,Object> hints) |
reactor.core.publisher.Flux<Part> |
DefaultPartHttpMessageReader.read(ResolvableType elementType,
ReactiveHttpInputMessage message,
Map<String,Object> hints) |
reactor.core.publisher.Mono<Part> |
SynchronossPartHttpMessageReader.readMono(ResolvableType elementType,
ReactiveHttpInputMessage message,
Map<String,Object> hints) |
reactor.core.publisher.Mono<MultiValueMap<String,Part>> |
MultipartHttpMessageReader.readMono(ResolvableType elementType,
ReactiveHttpInputMessage inputMessage,
Map<String,Object> hints) |
reactor.core.publisher.Mono<Part> |
DefaultPartHttpMessageReader.readMono(ResolvableType elementType,
ReactiveHttpInputMessage message,
Map<String,Object> hints) |
Modifier and Type | Interface and Description |
---|---|
interface |
ServerHttpRequest
Represents a reactive server-side HTTP request.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractServerHttpRequest
Common base class for
ServerHttpRequest implementations. |
class |
ServerHttpRequestDecorator
Wraps another
ServerHttpRequest and delegates all methods to it. |
Modifier and Type | Class and Description |
---|---|
class |
MockClientHttpResponse
Mock implementation of
ClientHttpResponse . |
Modifier and Type | Class and Description |
---|---|
class |
MockServerHttpRequest
Mock extension of
AbstractServerHttpRequest for use in tests without
an actual server. |
Modifier and Type | Interface and Description |
---|---|
interface |
MockServerClientHttpResponse
Simple
ClientHttpResponse extension that also exposes a result object
from the underlying mock server exchange for further assertions on the state
of the server response after the request is performed. |
Modifier and Type | Interface and Description |
---|---|
interface |
BodyExtractor<T,M extends ReactiveHttpInputMessage>
A function that can extract data from a
ReactiveHttpInputMessage body. |
Modifier and Type | Method and Description |
---|---|
static BodyExtractor<reactor.core.publisher.Flux<DataBuffer>,ReactiveHttpInputMessage> |
BodyExtractors.toDataBuffers()
Extractor that returns the raw
DataBuffers . |
static <T> BodyExtractor<reactor.core.publisher.Flux<T>,ReactiveHttpInputMessage> |
BodyExtractors.toFlux(Class<? extends T> elementClass)
Extractor to decode the input content into
Flux<T> . |
static <T> BodyExtractor<reactor.core.publisher.Flux<T>,ReactiveHttpInputMessage> |
BodyExtractors.toFlux(ParameterizedTypeReference<T> typeRef)
Variant of
BodyExtractors.toFlux(Class) for type information with generics. |
static BodyExtractor<reactor.core.publisher.Mono<MultiValueMap<String,String>>,ReactiveHttpInputMessage> |
BodyExtractors.toFormData()
Extractor to read form data into
MultiValueMap<String, String> . |
static <T> BodyExtractor<reactor.core.publisher.Mono<T>,ReactiveHttpInputMessage> |
BodyExtractors.toMono(Class<? extends T> elementClass)
Extractor to decode the input content into
Mono<T> . |
static <T> BodyExtractor<reactor.core.publisher.Mono<T>,ReactiveHttpInputMessage> |
BodyExtractors.toMono(ParameterizedTypeReference<T> elementTypeRef)
Variant of
BodyExtractors.toMono(Class) for type information with generics. |