Uses of Interface
org.springframework.core.io.buffer.DataBufferFactory
Package
Description
Generic abstraction for working with byte buffer implementations.
Contains a basic abstraction over client/server-side HTTP.
Abstractions for reactive HTTP client support including
ClientHttpRequest
and
ClientHttpResponse
as well as a
ClientHttpConnector
.CBOR encoder and decoder support.
JSON encoder and decoder support.
Multipart support.
Provides an encoder and a decoder for
Google Protocol Buffers.
XML encoder and decoder support.
Abstractions for reactive HTTP server support including a
ServerHttpRequest
and
ServerHttpResponse
along with an
HttpHandler
for processing.Support for the RSocket protocol.
Mock implementations of reactive HTTP client contracts.
Mock implementations of reactive HTTP server contracts.
Provides extensible support for initializing databases through scripts.
Abstractions and support classes for reactive WebSocket interactions.
Classes adapting Spring's Reactive WebSocket API to and from WebSocket runtimes.
Client support for WebSocket interactions.
-
Uses of DataBufferFactory in org.springframework.core.codec
Modifier and TypeMethodDescriptionfinal reactor.core.publisher.Flux<DataBuffer>
AbstractSingleValueEncoder.encode
(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
(Publisher<? extends byte[]> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, Map<String, Object> hints) reactor.core.publisher.Flux<DataBuffer>
ByteBufferEncoder.encode
(Publisher<? extends ByteBuffer> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, Map<String, Object> hints) reactor.core.publisher.Flux<DataBuffer>
CharSequenceEncoder.encode
(Publisher<? extends CharSequence> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, Map<String, Object> hints) reactor.core.publisher.Flux<DataBuffer>
DataBufferEncoder.encode
(Publisher<? extends DataBuffer> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, Map<String, Object> hints) reactor.core.publisher.Flux<DataBuffer>
Encoder.encode
(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.reactor.core.publisher.Flux<DataBuffer>
Netty5BufferEncoder.encode
(Publisher<? extends io.netty5.buffer.Buffer> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, Map<String, Object> hints) reactor.core.publisher.Flux<DataBuffer>
NettyByteBufEncoder.encode
(Publisher<? extends io.netty.buffer.ByteBuf> 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) reactor.core.publisher.Flux<DataBuffer>
ResourceRegionEncoder.encode
(Publisher<? extends ResourceRegion> input, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, Map<String, Object> hints) ByteArrayEncoder.encodeValue
(byte[] bytes, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, Map<String, Object> hints) ByteBufferEncoder.encodeValue
(ByteBuffer byteBuffer, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, Map<String, Object> hints) CharSequenceEncoder.encodeValue
(CharSequence charSequence, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, Map<String, Object> hints) 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.Netty5BufferEncoder.encodeValue
(io.netty5.buffer.Buffer buffer, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, Map<String, Object> hints) NettyByteBufEncoder.encodeValue
(io.netty.buffer.ByteBuf byteBuf, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, Map<String, Object> hints) -
Uses of DataBufferFactory in org.springframework.core.io.buffer
Modifier and TypeClassDescriptionclass
Default implementation of theDataBufferFactory
interface.class
Implementation of theDataBufferFactory
interface based on a Netty 5BufferAllocator
.class
Implementation of theDataBufferFactory
interface based on a Netty 4ByteBufAllocator
.Modifier and TypeMethodDescriptionDataBuffer.factory()
Return theDataBufferFactory
that created this buffer.DataBufferWrapper.factory()
Netty5DataBuffer.factory()
Modifier and TypeMethodDescriptionstatic Publisher<DataBuffer>
DataBufferUtils.outputStreamPublisher
(Consumer<OutputStream> outputStreamConsumer, DataBufferFactory bufferFactory, Executor executor) Create a newPublisher<DataBuffer>
based on bytes written to aOutputStream
.static Publisher<DataBuffer>
DataBufferUtils.outputStreamPublisher
(Consumer<OutputStream> outputStreamConsumer, DataBufferFactory bufferFactory, Executor executor, int chunkSize) Creates a newPublisher<DataBuffer>
based on bytes written to aOutputStream
.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 anAsynchronousFileChannel
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
Modifier and TypeMethodDescriptionReactiveHttpOutputMessage.bufferFactory()
Return aDataBufferFactory
that can be used to create the body. -
Uses of DataBufferFactory in org.springframework.http.client.reactive
Modifier and TypeMethodDescriptionvoid
HttpComponentsClientHttpConnector.setBufferFactory
(DataBufferFactory bufferFactory) Set the buffer factory to use.void
JdkClientHttpConnector.setBufferFactory
(DataBufferFactory bufferFactory) Set the buffer factory to use.void
JettyClientHttpConnector.setBufferFactory
(DataBufferFactory bufferFactory) Set the buffer factory to use. -
Uses of DataBufferFactory in org.springframework.http.codec
Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<DataBuffer>
KotlinSerializationBinaryEncoder.encode
(Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, Map<String, Object> hints) reactor.core.publisher.Flux<DataBuffer>
KotlinSerializationStringEncoder.encode
(Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, Map<String, Object> hints) KotlinSerializationBinaryEncoder.encodeValue
(Object value, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, Map<String, Object> hints) KotlinSerializationStringEncoder.encodeValue
(Object value, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, Map<String, Object> hints) -
Uses of DataBufferFactory in org.springframework.http.codec.cbor
Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<DataBuffer>
Jackson2CborEncoder.encode
(Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, Map<String, Object> hints) -
Uses of DataBufferFactory in org.springframework.http.codec.json
Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<DataBuffer>
AbstractJackson2Encoder.encode
(Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, Map<String, Object> hints) AbstractJackson2Encoder.encodeValue
(Object value, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, Map<String, Object> hints) -
Uses of DataBufferFactory in org.springframework.http.codec.multipart
Modifier and TypeMethodDescriptionprotected reactor.core.publisher.Mono<DataBuffer>
MultipartWriterSupport.generateBoundaryLine
(byte[] boundary, DataBufferFactory bufferFactory) protected reactor.core.publisher.Mono<DataBuffer>
MultipartWriterSupport.generateLastLine
(byte[] boundary, DataBufferFactory bufferFactory) protected reactor.core.publisher.Mono<DataBuffer>
MultipartWriterSupport.generateNewLine
(DataBufferFactory bufferFactory) protected reactor.core.publisher.Mono<DataBuffer>
MultipartWriterSupport.generatePartHeaders
(HttpHeaders headers, DataBufferFactory bufferFactory) -
Uses of DataBufferFactory in org.springframework.http.codec.protobuf
Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<DataBuffer>
ProtobufEncoder.encode
(Publisher<? extends com.google.protobuf.Message> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, Map<String, Object> hints) 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
Modifier and TypeMethodDescriptionprotected reactor.core.publisher.Flux<DataBuffer>
Jaxb2XmlEncoder.encode
(Object value, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, Map<String, Object> hints) Jaxb2XmlEncoder.encodeValue
(Object value, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, Map<String, Object> hints) -
Uses of DataBufferFactory in org.springframework.http.server.reactive
Modifier and TypeMethodDescriptionfinal DataBufferFactory
AbstractServerHttpResponse.bufferFactory()
ServerHttpResponseDecorator.bufferFactory()
ServletHttpHandlerAdapter.getDataBufferFactory()
UndertowHttpHandlerAdapter.getDataBufferFactory()
Modifier and TypeMethodDescriptionvoid
ServletHttpHandlerAdapter.setDataBufferFactory
(DataBufferFactory dataBufferFactory) void
UndertowHttpHandlerAdapter.setDataBufferFactory
(DataBufferFactory bufferFactory) ModifierConstructorDescriptionAbstractListenerServerHttpResponse
(DataBufferFactory bufferFactory) AbstractListenerServerHttpResponse
(DataBufferFactory bufferFactory, HttpHeaders headers) AbstractServerHttpResponse
(DataBufferFactory dataBufferFactory) AbstractServerHttpResponse
(DataBufferFactory dataBufferFactory, HttpHeaders headers) -
Uses of DataBufferFactory in org.springframework.messaging.rsocket
Modifier and TypeMethodDescriptionRSocketStrategies.dataBufferFactory()
Return the configureddataBufferFactory
.Modifier and TypeMethodDescriptionRSocketStrategies.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
-
Uses of DataBufferFactory in org.springframework.mock.http.server.reactive
-
Uses of DataBufferFactory in org.springframework.r2dbc.connection.init
Modifier and TypeMethodDescriptionstatic reactor.core.publisher.Mono<Void>
ScriptUtils.executeSqlScript
(Connection connection, EncodedResource resource, DataBufferFactory dataBufferFactory, boolean continueOnError, boolean ignoreFailedDrops, String[] commentPrefixes, String separator, String blockCommentStartDelimiter, String blockCommentEndDelimiter) Execute the given SQL script.static reactor.core.publisher.Mono<Void>
ScriptUtils.executeSqlScript
(Connection connection, EncodedResource resource, DataBufferFactory dataBufferFactory, boolean continueOnError, boolean ignoreFailedDrops, String commentPrefix, String separator, String blockCommentStartDelimiter, String blockCommentEndDelimiter) Execute the given SQL script.void
ResourceDatabasePopulator.setDataBufferFactory
(DataBufferFactory dataBufferFactory) Set theDataBufferFactory
to use forResource
loading. -
Uses of DataBufferFactory in org.springframework.web.reactive.socket
Modifier and TypeMethodDescriptionWebSocketSession.bufferFactory()
Return aDataBuffer
Factory to create message payloads.Modifier and TypeMethodDescriptionWebSocketSession.binaryMessage
(Function<DataBufferFactory, DataBuffer> payloadFactory) Factory method to create a binary WebSocketMessage using theWebSocketSession.bufferFactory()
for the session.WebSocketSession.pingMessage
(Function<DataBufferFactory, DataBuffer> payloadFactory) Factory method to create a ping WebSocketMessage using theWebSocketSession.bufferFactory()
for the session.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
Modifier and TypeMethodDescriptionAbstractWebSocketSession.binaryMessage
(Function<DataBufferFactory, DataBuffer> payloadFactory) AbstractWebSocketSession.pingMessage
(Function<DataBufferFactory, DataBuffer> payloadFactory) AbstractWebSocketSession.pongMessage
(Function<DataBufferFactory, DataBuffer> payloadFactory) ModifierConstructorDescriptionAbstractListenerWebSocketSession
(T delegate, String id, HandshakeInfo info, DataBufferFactory bufferFactory) Base constructor.AbstractListenerWebSocketSession
(T delegate, String id, HandshakeInfo info, DataBufferFactory bufferFactory, reactor.core.publisher.Sinks.Empty<Void> handlerCompletionSink) Alternative constructor with completion sink to use to signal when the handling of the session is complete, with success or error.protected
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.Sinks.Empty<Void> completionSink) StandardWebSocketSession
(Session session, HandshakeInfo info, DataBufferFactory factory) StandardWebSocketSession
(Session session, HandshakeInfo info, DataBufferFactory factory, reactor.core.publisher.Sinks.Empty<Void> completionSink) TomcatWebSocketSession
(Session session, HandshakeInfo info, DataBufferFactory factory) TomcatWebSocketSession
(Session session, HandshakeInfo info, DataBufferFactory factory, reactor.core.publisher.Sinks.Empty<Void> completionSink) 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.Sinks.Empty<Void> completionSink) -
Uses of DataBufferFactory in org.springframework.web.reactive.socket.client
Modifier and TypeMethodDescriptionprotected DataBufferFactory
StandardWebSocketClient.bufferFactory()
Return theDataBufferFactory
to use.