Uses of Interface
org.springframework.core.io.buffer.DataBufferFactory
Packages that use DataBufferFactory 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 includingClientHttpRequest
andClientHttpResponse
as well as aClientHttpConnector
.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 aServerHttpRequest
andServerHttpResponse
along with anHttpHandler
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.Uses of DataBufferFactory in org.springframework.core.codec
Methods in org.springframework.core.codec with parameters of type DataBufferFactory Modifier and Type Method Description reactor.core.publisher.Flux<DataBuffer>
AbstractSingleValueEncoder. encode(org.reactivestreams.Publisher<? extends T> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, 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)
EncodeT
to an outputDataBuffer
stream.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>
Encoder. encode(org.reactivestreams.Publisher<? extends T> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
Encode a stream of Objects of typeT
into aDataBuffer
output stream.protected reactor.core.publisher.Flux<DataBuffer>
ResourceEncoder. encode(Resource resource, DataBufferFactory bufferFactory, ResolvableType type, 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)
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.Uses of DataBufferFactory in org.springframework.core.io.buffer
Classes in org.springframework.core.io.buffer that implement DataBufferFactory Modifier and Type Class Description class
DefaultDataBufferFactory
Default implementation of theDataBufferFactory
interface.class
NettyDataBufferFactory
Implementation of theDataBufferFactory
interface based on a NettyByteBufAllocator
.Methods in org.springframework.core.io.buffer that return DataBufferFactory Modifier and Type Method Description DataBufferFactory
DataBuffer. factory()
Return theDataBufferFactory
that created this buffer.DataBufferFactory
DataBufferWrapper. factory()
Methods in org.springframework.core.io.buffer with parameters of type DataBufferFactory Modifier and Type Method Description static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils. read(Path path, DataBufferFactory bufferFactory, int bufferSize, OpenOption... options)
Read bytes from the given filePath
into aFlux
ofDataBuffer
s.static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils. read(Resource resource, long position, DataBufferFactory bufferFactory, int bufferSize)
Read the givenResource
into aFlux
ofDataBuffer
s starting at the given position.static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils. read(Resource resource, DataBufferFactory bufferFactory, int bufferSize)
Read the givenResource
into aFlux
ofDataBuffer
s.static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils. readAsynchronousFileChannel(Callable<AsynchronousFileChannel> channelSupplier, long position, DataBufferFactory bufferFactory, int bufferSize)
Obtain aAsynchronousFileChannel
from the given supplier, and read it into aFlux
ofDataBuffer
s, starting at the given position.static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils. readAsynchronousFileChannel(Callable<AsynchronousFileChannel> channelSupplier, DataBufferFactory bufferFactory, int bufferSize)
Obtain aAsynchronousFileChannel
from the given supplier, and read it into aFlux
ofDataBuffer
s.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)
Uses of DataBufferFactory in org.springframework.http
Methods in org.springframework.http that return DataBufferFactory Modifier and Type Method Description DataBufferFactory
ReactiveHttpOutputMessage. bufferFactory()
Return aDataBufferFactory
that can be used to create the body.Uses of DataBufferFactory in org.springframework.http.client.reactive
Methods in org.springframework.http.client.reactive that return DataBufferFactory Modifier and Type Method Description DataBufferFactory
ClientHttpRequestDecorator. bufferFactory()
Methods in org.springframework.http.client.reactive with parameters of type DataBufferFactory Modifier and Type Method Description void
JettyClientHttpConnector. setBufferFactory(DataBufferFactory bufferFactory)
Uses of DataBufferFactory in org.springframework.http.codec.cbor
Methods in org.springframework.http.codec.cbor with parameters of type DataBufferFactory Modifier and Type Method Description reactor.core.publisher.Flux<DataBuffer>
Jackson2CborEncoder. encode(org.reactivestreams.Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
Uses of DataBufferFactory in org.springframework.http.codec.json
Methods in org.springframework.http.codec.json with parameters of type DataBufferFactory Modifier and Type Method 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)
Uses of DataBufferFactory in org.springframework.http.codec.protobuf
Methods in org.springframework.http.codec.protobuf with parameters of type DataBufferFactory Modifier and Type Method 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)
Uses of DataBufferFactory in org.springframework.http.codec.xml
Methods in org.springframework.http.codec.xml with parameters of type DataBufferFactory Modifier and Type Method 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)
Uses of DataBufferFactory in org.springframework.http.server.reactive
Methods in org.springframework.http.server.reactive that return DataBufferFactory Modifier and Type Method Description DataBufferFactory
AbstractServerHttpResponse. bufferFactory()
DataBufferFactory
ServerHttpResponseDecorator. bufferFactory()
DataBufferFactory
ServletHttpHandlerAdapter. getDataBufferFactory()
DataBufferFactory
UndertowHttpHandlerAdapter. getDataBufferFactory()
Methods in org.springframework.http.server.reactive with parameters of type DataBufferFactory Modifier and Type Method Description void
ServletHttpHandlerAdapter. setDataBufferFactory(DataBufferFactory dataBufferFactory)
void
UndertowHttpHandlerAdapter. setDataBufferFactory(DataBufferFactory bufferFactory)
Constructors in org.springframework.http.server.reactive with parameters of type DataBufferFactory Constructor Description AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory)
AbstractListenerServerHttpResponse(DataBufferFactory dataBufferFactory, HttpHeaders headers)
AbstractServerHttpResponse(DataBufferFactory dataBufferFactory)
AbstractServerHttpResponse(DataBufferFactory dataBufferFactory, HttpHeaders headers)
Uses of DataBufferFactory in org.springframework.messaging.rsocket
Methods in org.springframework.messaging.rsocket that return DataBufferFactory Modifier and Type Method Description DataBufferFactory
RSocketStrategies. dataBufferFactory()
Return the configureddataBufferFactory
.Methods in org.springframework.messaging.rsocket with parameters of type DataBufferFactory Modifier and Type Method 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 thePayload
, and also to release thePayload
.Uses of DataBufferFactory in org.springframework.mock.http.client.reactive
Methods in org.springframework.mock.http.client.reactive that return DataBufferFactory Modifier and Type Method Description DataBufferFactory
MockClientHttpRequest. bufferFactory()
Uses of DataBufferFactory in org.springframework.mock.http.server.reactive
Constructors in org.springframework.mock.http.server.reactive with parameters of type DataBufferFactory Constructor Description MockServerHttpResponse(DataBufferFactory dataBufferFactory)
Uses of DataBufferFactory in org.springframework.web.reactive.socket
Methods in org.springframework.web.reactive.socket that return DataBufferFactory Modifier and Type Method Description DataBufferFactory
WebSocketSession. bufferFactory()
Return aDataBuffer
Factory to create message payloads.Method parameters in org.springframework.web.reactive.socket with type arguments of type DataBufferFactory Modifier and Type Method Description WebSocketMessage
WebSocketSession. binaryMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)
Factory method to create a binary WebSocketMessage using theWebSocketSession.bufferFactory()
for the session.WebSocketMessage
WebSocketSession. pingMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)
Factory method to create a ping WebSocketMessage using theWebSocketSession.bufferFactory()
for the session.WebSocketMessage
WebSocketSession. pongMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)
Factory method to create a pong WebSocketMessage using theWebSocketSession.bufferFactory()
for the session.Uses of DataBufferFactory in org.springframework.web.reactive.socket.adapter
Methods in org.springframework.web.reactive.socket.adapter that return DataBufferFactory Modifier and Type Method Description DataBufferFactory
AbstractWebSocketSession. bufferFactory()
Method parameters in org.springframework.web.reactive.socket.adapter with type arguments of type DataBufferFactory Modifier and Type Method Description WebSocketMessage
AbstractWebSocketSession. binaryMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)
WebSocketMessage
AbstractWebSocketSession. pingMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)
WebSocketMessage
AbstractWebSocketSession. pongMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)
Constructors in org.springframework.web.reactive.socket.adapter with parameters of type DataBufferFactory Constructor 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 completionMono<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)
Uses of DataBufferFactory in org.springframework.web.reactive.socket.client
Methods in org.springframework.web.reactive.socket.client that return DataBufferFactory Modifier and Type Method Description protected DataBufferFactory
StandardWebSocketClient. bufferFactory()