Uses of Interface
org.springframework.core.io.buffer.DataBufferFactory
Packages that use 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
Methods in org.springframework.core.codec with parameters of type DataBufferFactoryModifier 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
Classes in org.springframework.core.io.buffer that implement DataBufferFactoryModifier 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
.Methods in org.springframework.core.io.buffer that return DataBufferFactoryModifier and TypeMethodDescriptionDataBuffer.factory()
Return theDataBufferFactory
that created this buffer.DataBufferWrapper.factory()
Netty5DataBuffer.factory()
Methods in org.springframework.core.io.buffer with parameters of type DataBufferFactoryModifier 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
Methods in org.springframework.http that return DataBufferFactoryModifier and TypeMethodDescriptionReactiveHttpOutputMessage.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 DataBufferFactoryMethods in org.springframework.http.client.reactive with parameters of type DataBufferFactoryModifier 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
Methods in org.springframework.http.codec with parameters of type DataBufferFactoryModifier 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
Methods in org.springframework.http.codec.cbor with parameters of type DataBufferFactoryModifier 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
Methods in org.springframework.http.codec.json with parameters of type DataBufferFactoryModifier 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
Methods in org.springframework.http.codec.multipart with parameters of type DataBufferFactoryModifier 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
Methods in org.springframework.http.codec.protobuf with parameters of type DataBufferFactoryModifier 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
Methods in org.springframework.http.codec.xml with parameters of type DataBufferFactoryModifier 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
Methods in org.springframework.http.server.reactive that return DataBufferFactoryModifier and TypeMethodDescriptionfinal DataBufferFactory
AbstractServerHttpResponse.bufferFactory()
ServerHttpResponseDecorator.bufferFactory()
ServletHttpHandlerAdapter.getDataBufferFactory()
UndertowHttpHandlerAdapter.getDataBufferFactory()
Methods in org.springframework.http.server.reactive with parameters of type DataBufferFactoryModifier and TypeMethodDescriptionvoid
ServletHttpHandlerAdapter.setDataBufferFactory
(DataBufferFactory dataBufferFactory) void
UndertowHttpHandlerAdapter.setDataBufferFactory
(DataBufferFactory bufferFactory) Constructors in org.springframework.http.server.reactive with parameters of type DataBufferFactoryModifierConstructorDescriptionAbstractListenerServerHttpResponse
(DataBufferFactory bufferFactory) AbstractListenerServerHttpResponse
(DataBufferFactory bufferFactory, 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 DataBufferFactoryModifier and TypeMethodDescriptionRSocketStrategies.dataBufferFactory()
Return the configureddataBufferFactory
.Methods in org.springframework.messaging.rsocket with parameters of type DataBufferFactoryModifier 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
Methods in org.springframework.mock.http.client.reactive that return DataBufferFactory -
Uses of DataBufferFactory in org.springframework.mock.http.server.reactive
Constructors in org.springframework.mock.http.server.reactive with parameters of type DataBufferFactory -
Uses of DataBufferFactory in org.springframework.r2dbc.connection.init
Methods in org.springframework.r2dbc.connection.init with parameters of type DataBufferFactoryModifier 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
Methods in org.springframework.web.reactive.socket that return DataBufferFactoryModifier and TypeMethodDescriptionWebSocketSession.bufferFactory()
Return aDataBuffer
Factory to create message payloads.Method parameters in org.springframework.web.reactive.socket with type arguments of type DataBufferFactoryModifier 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
Methods in org.springframework.web.reactive.socket.adapter that return DataBufferFactoryMethod parameters in org.springframework.web.reactive.socket.adapter with type arguments of type DataBufferFactoryModifier and TypeMethodDescriptionAbstractWebSocketSession.binaryMessage
(Function<DataBufferFactory, DataBuffer> payloadFactory) AbstractWebSocketSession.pingMessage
(Function<DataBufferFactory, DataBuffer> payloadFactory) AbstractWebSocketSession.pongMessage
(Function<DataBufferFactory, DataBuffer> payloadFactory) Constructors in org.springframework.web.reactive.socket.adapter with parameters of type DataBufferFactoryModifierConstructorDescriptionAbstractListenerWebSocketSession
(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
Methods in org.springframework.web.reactive.socket.client that return DataBufferFactoryModifier and TypeMethodDescriptionprotected DataBufferFactory
StandardWebSocketClient.bufferFactory()
Return theDataBufferFactory
to use.