Package | Description |
---|---|
org.springframework.core.codec | |
org.springframework.core.io.buffer |
Generic abstraction for working with byte buffer implementations.
|
org.springframework.http |
Contains a basic abstraction over client/server-side HTTP.
|
org.springframework.http.client.reactive |
Abstractions for reactive HTTP client support including
ClientHttpRequest and
ClientHttpResponse as well as a
ClientHttpConnector . |
org.springframework.http.codec.cbor | |
org.springframework.http.codec.json |
JSON encoder and decoder support.
|
org.springframework.http.codec.protobuf |
Provides an encoder and a decoder for
Google Protocol Buffers.
|
org.springframework.http.codec.xml |
XML encoder and decoder 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.messaging.rsocket |
Support for the RSocket protocol.
|
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.web.reactive.socket |
Abstractions and support classes for reactive WebSocket interactions.
|
org.springframework.web.reactive.socket.adapter |
Classes adapting Spring's Reactive WebSocket API to and from WebSocket runtimes.
|
org.springframework.web.reactive.socket.client |
Client support for WebSocket interactions.
|
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<DataBuffer> |
ByteArrayEncoder.encode(org.reactivestreams.Publisher<? extends byte[]> inputStream,
DataBufferFactory bufferFactory,
ResolvableType elementType,
MimeType mimeType,
Map<String,Object> hints) |
reactor.core.publisher.Flux<DataBuffer> |
ByteBufferEncoder.encode(org.reactivestreams.Publisher<? extends ByteBuffer> inputStream,
DataBufferFactory bufferFactory,
ResolvableType elementType,
MimeType mimeType,
Map<String,Object> hints) |
reactor.core.publisher.Flux<DataBuffer> |
CharSequenceEncoder.encode(org.reactivestreams.Publisher<? extends CharSequence> inputStream,
DataBufferFactory bufferFactory,
ResolvableType elementType,
MimeType mimeType,
Map<String,Object> hints) |
reactor.core.publisher.Flux<DataBuffer> |
DataBufferEncoder.encode(org.reactivestreams.Publisher<? extends DataBuffer> inputStream,
DataBufferFactory bufferFactory,
ResolvableType elementType,
MimeType mimeType,
Map<String,Object> hints) |
reactor.core.publisher.Flux<DataBuffer> |
ResourceRegionEncoder.encode(org.reactivestreams.Publisher<? extends ResourceRegion> input,
DataBufferFactory bufferFactory,
ResolvableType elementType,
MimeType mimeType,
Map<String,Object> hints) |
reactor.core.publisher.Flux<DataBuffer> |
Encoder.encode(org.reactivestreams.Publisher<? extends T> inputStream,
DataBufferFactory bufferFactory,
ResolvableType elementType,
MimeType mimeType,
Map<String,Object> hints)
Encode a stream of Objects of type
T into a DataBuffer
output stream. |
reactor.core.publisher.Flux<DataBuffer> |
AbstractSingleValueEncoder.encode(org.reactivestreams.Publisher<? extends T> inputStream,
DataBufferFactory bufferFactory,
ResolvableType elementType,
MimeType mimeType,
Map<String,Object> hints) |
protected reactor.core.publisher.Flux<DataBuffer> |
ResourceEncoder.encode(Resource resource,
DataBufferFactory bufferFactory,
ResolvableType type,
MimeType mimeType,
Map<String,Object> hints) |
protected abstract reactor.core.publisher.Flux<DataBuffer> |
AbstractSingleValueEncoder.encode(T t,
DataBufferFactory dataBufferFactory,
ResolvableType type,
MimeType mimeType,
Map<String,Object> hints)
Encode
T to an output DataBuffer stream. |
DataBuffer |
ByteArrayEncoder.encodeValue(byte[] bytes,
DataBufferFactory bufferFactory,
ResolvableType valueType,
MimeType mimeType,
Map<String,Object> hints) |
DataBuffer |
ByteBufferEncoder.encodeValue(ByteBuffer byteBuffer,
DataBufferFactory bufferFactory,
ResolvableType valueType,
MimeType mimeType,
Map<String,Object> hints) |
DataBuffer |
CharSequenceEncoder.encodeValue(CharSequence charSequence,
DataBufferFactory bufferFactory,
ResolvableType valueType,
MimeType mimeType,
Map<String,Object> hints) |
DataBuffer |
DataBufferEncoder.encodeValue(DataBuffer buffer,
DataBufferFactory bufferFactory,
ResolvableType valueType,
MimeType mimeType,
Map<String,Object> hints) |
default DataBuffer |
Encoder.encodeValue(T value,
DataBufferFactory bufferFactory,
ResolvableType valueType,
MimeType mimeType,
Map<String,Object> hints)
Encode an Object of type T to a data buffer.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultDataBufferFactory
Default implementation of the
DataBufferFactory interface. |
class |
NettyDataBufferFactory
Implementation of the
DataBufferFactory interface based on a
Netty ByteBufAllocator . |
Modifier and Type | Method and Description |
---|---|
DataBufferFactory |
DataBuffer.factory()
Return the
DataBufferFactory that created this buffer. |
DataBufferFactory |
DataBufferWrapper.factory() |
Modifier and Type | Method and Description |
---|---|
static reactor.core.publisher.Flux<DataBuffer> |
DataBufferUtils.read(Path path,
DataBufferFactory bufferFactory,
int bufferSize,
OpenOption... options)
Read bytes from the given file
Path into a Flux of DataBuffer s. |
static reactor.core.publisher.Flux<DataBuffer> |
DataBufferUtils.read(Resource resource,
DataBufferFactory bufferFactory,
int bufferSize)
Read the given
Resource into a Flux of DataBuffer s. |
static reactor.core.publisher.Flux<DataBuffer> |
DataBufferUtils.read(Resource resource,
long position,
DataBufferFactory bufferFactory,
int bufferSize)
Read the given
Resource into a Flux of DataBuffer s
starting at the given position. |
static reactor.core.publisher.Flux<DataBuffer> |
DataBufferUtils.readAsynchronousFileChannel(Callable<AsynchronousFileChannel> channelSupplier,
DataBufferFactory bufferFactory,
int bufferSize)
Obtain a
AsynchronousFileChannel from the given supplier, and read
it into a Flux of DataBuffer s. |
static reactor.core.publisher.Flux<DataBuffer> |
DataBufferUtils.readAsynchronousFileChannel(Callable<AsynchronousFileChannel> channelSupplier,
long position,
DataBufferFactory bufferFactory,
int bufferSize)
Obtain a
AsynchronousFileChannel from the given supplier, and
read it into a Flux of DataBuffer s, starting at the given
position. |
static reactor.core.publisher.Flux<DataBuffer> |
DataBufferUtils.readByteChannel(Callable<ReadableByteChannel> channelSupplier,
DataBufferFactory bufferFactory,
int bufferSize)
|
static reactor.core.publisher.Flux<DataBuffer> |
DataBufferUtils.readInputStream(Callable<InputStream> inputStreamSupplier,
DataBufferFactory bufferFactory,
int bufferSize)
|
Modifier and Type | Method and Description |
---|---|
DataBufferFactory |
ReactiveHttpOutputMessage.bufferFactory()
Return a
DataBufferFactory that can be used to create the body. |
Modifier and Type | Method and Description |
---|---|
DataBufferFactory |
ClientHttpRequestDecorator.bufferFactory() |
Modifier and Type | Method and Description |
---|---|
void |
JettyClientHttpConnector.setBufferFactory(DataBufferFactory bufferFactory) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<DataBuffer> |
Jackson2CborEncoder.encode(org.reactivestreams.Publisher<?> inputStream,
DataBufferFactory bufferFactory,
ResolvableType elementType,
MimeType mimeType,
Map<String,Object> hints) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<DataBuffer> |
AbstractJackson2Encoder.encode(org.reactivestreams.Publisher<?> inputStream,
DataBufferFactory bufferFactory,
ResolvableType elementType,
MimeType mimeType,
Map<String,Object> hints) |
DataBuffer |
AbstractJackson2Encoder.encodeValue(Object value,
DataBufferFactory bufferFactory,
ResolvableType valueType,
MimeType mimeType,
Map<String,Object> hints) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<DataBuffer> |
ProtobufEncoder.encode(org.reactivestreams.Publisher<? extends com.google.protobuf.Message> inputStream,
DataBufferFactory bufferFactory,
ResolvableType elementType,
MimeType mimeType,
Map<String,Object> hints) |
DataBuffer |
ProtobufEncoder.encodeValue(com.google.protobuf.Message message,
DataBufferFactory bufferFactory,
ResolvableType valueType,
MimeType mimeType,
Map<String,Object> hints) |
Modifier and Type | Method and Description |
---|---|
protected reactor.core.publisher.Flux<DataBuffer> |
Jaxb2XmlEncoder.encode(Object value,
DataBufferFactory bufferFactory,
ResolvableType valueType,
MimeType mimeType,
Map<String,Object> hints) |
DataBuffer |
Jaxb2XmlEncoder.encodeValue(Object value,
DataBufferFactory bufferFactory,
ResolvableType valueType,
MimeType mimeType,
Map<String,Object> hints) |
Modifier and Type | Method and Description |
---|---|
DataBufferFactory |
ServerHttpResponseDecorator.bufferFactory() |
DataBufferFactory |
AbstractServerHttpResponse.bufferFactory() |
DataBufferFactory |
UndertowHttpHandlerAdapter.getDataBufferFactory() |
DataBufferFactory |
ServletHttpHandlerAdapter.getDataBufferFactory() |
Modifier and Type | Method and Description |
---|---|
void |
UndertowHttpHandlerAdapter.setDataBufferFactory(DataBufferFactory bufferFactory) |
void |
ServletHttpHandlerAdapter.setDataBufferFactory(DataBufferFactory dataBufferFactory) |
Constructor and Description |
---|
AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory) |
AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory,
HttpHeaders headers) |
AbstractServerHttpResponse(DataBufferFactory dataBufferFactory) |
AbstractServerHttpResponse(DataBufferFactory dataBufferFactory,
HttpHeaders headers) |
Modifier and Type | Method and Description |
---|---|
DataBufferFactory |
RSocketStrategies.dataBufferFactory()
Return the configured
dataBufferFactory . |
Modifier and Type | Method and Description |
---|---|
RSocketStrategies.Builder |
RSocketStrategies.Builder.dataBufferFactory(DataBufferFactory bufferFactory)
Configure the DataBufferFactory to use for allocating buffers when
preparing requests or creating responses.
|
static DataBuffer |
PayloadUtils.retainDataAndReleasePayload(io.rsocket.Payload payload,
DataBufferFactory bufferFactory)
Use this method to slice, retain and wrap the data portion of the
Payload , and also to release the Payload . |
Modifier and Type | Method and Description |
---|---|
DataBufferFactory |
MockClientHttpRequest.bufferFactory() |
Constructor and Description |
---|
MockServerHttpResponse(DataBufferFactory dataBufferFactory) |
Modifier and Type | Method and Description |
---|---|
DataBufferFactory |
WebSocketSession.bufferFactory()
Return a
DataBuffer Factory to create message payloads. |
Modifier and Type | Method and Description |
---|---|
WebSocketMessage |
WebSocketSession.binaryMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)
Factory method to create a binary WebSocketMessage using the
WebSocketSession.bufferFactory() for the session. |
WebSocketMessage |
WebSocketSession.pingMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)
Factory method to create a ping WebSocketMessage using the
WebSocketSession.bufferFactory() for the session. |
WebSocketMessage |
WebSocketSession.pongMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)
Factory method to create a pong WebSocketMessage using the
WebSocketSession.bufferFactory() for the session. |
Modifier and Type | Method and Description |
---|---|
DataBufferFactory |
AbstractWebSocketSession.bufferFactory() |
Modifier and Type | Method and Description |
---|---|
WebSocketMessage |
AbstractWebSocketSession.binaryMessage(Function<DataBufferFactory,DataBuffer> payloadFactory) |
WebSocketMessage |
AbstractWebSocketSession.pingMessage(Function<DataBufferFactory,DataBuffer> payloadFactory) |
WebSocketMessage |
AbstractWebSocketSession.pongMessage(Function<DataBufferFactory,DataBuffer> payloadFactory) |
Constructor and Description |
---|
AbstractListenerWebSocketSession(T delegate,
String id,
HandshakeInfo handshakeInfo,
DataBufferFactory bufferFactory)
Base constructor.
|
AbstractListenerWebSocketSession(T delegate,
String id,
HandshakeInfo info,
DataBufferFactory bufferFactory,
reactor.core.publisher.MonoProcessor<Void> completionMono)
Alternative constructor with completion
Mono<Void> to propagate
the session completion (success or error) (for client-side use). |
AbstractWebSocketSession(T delegate,
String id,
HandshakeInfo info,
DataBufferFactory bufferFactory)
Create a new WebSocket session.
|
JettyWebSocketSession(org.eclipse.jetty.websocket.api.Session session,
HandshakeInfo info,
DataBufferFactory factory) |
JettyWebSocketSession(org.eclipse.jetty.websocket.api.Session session,
HandshakeInfo info,
DataBufferFactory factory,
reactor.core.publisher.MonoProcessor<Void> completionMono) |
StandardWebSocketSession(Session session,
HandshakeInfo info,
DataBufferFactory factory) |
StandardWebSocketSession(Session session,
HandshakeInfo info,
DataBufferFactory factory,
reactor.core.publisher.MonoProcessor<Void> completionMono) |
TomcatWebSocketSession(Session session,
HandshakeInfo info,
DataBufferFactory factory) |
TomcatWebSocketSession(Session session,
HandshakeInfo info,
DataBufferFactory factory,
reactor.core.publisher.MonoProcessor<Void> completionMono) |
UndertowWebSocketSession(io.undertow.websockets.core.WebSocketChannel channel,
HandshakeInfo info,
DataBufferFactory factory) |
UndertowWebSocketSession(io.undertow.websockets.core.WebSocketChannel channel,
HandshakeInfo info,
DataBufferFactory factory,
reactor.core.publisher.MonoProcessor<Void> completionMono) |
Modifier and Type | Method and Description |
---|---|
protected DataBufferFactory |
StandardWebSocketClient.bufferFactory() |