Uses of Interface
org.springframework.core.io.buffer.DataBuffer

Packages that use DataBuffer

Package	Description
org.springframework.core.codec	Encoder and Decoder abstractions to convert between a reactive stream of bytes and Java objects.
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	Provides implementations of Encoder and Decoder for web use.
org.springframework.http.codec.cbor	CBOR encoder and decoder support.
org.springframework.http.codec.json	JSON encoder and decoder support.
org.springframework.http.codec.multipart	Multipart 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.handler.invocation.reactive	Common infrastructure for invoking message handler methods with non-blocking, and reactive contracts.
org.springframework.messaging.rsocket	Support for the RSocket protocol.
org.springframework.messaging.rsocket.annotation.support	Support classes for working with annotated RSocket stream handling methods.
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.function	Provides a foundation for both the reactive client and server subpackages.
org.springframework.web.reactive.function.client	Provides a reactive WebClient that builds on top of the org.springframework.http.client.reactive reactive HTTP adapter layer.
org.springframework.web.reactive.function.server	Provides the types that make up Spring's functional web framework for Reactive environments.
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.

Uses of DataBuffer in org.springframework.core.codec

Subclasses with type arguments of type DataBuffer in org.springframework.core.codec

Modifier and Type	Class	Description
class	DataBufferDecoder	Simple pass-through decoder for DataBuffers.
class	DataBufferEncoder	Simple pass-through encoder for DataBuffers.

Methods in org.springframework.core.codec that return DataBuffer

Modifier and Type	Method	Description
DataBuffer	DataBufferDecoder.decode(DataBuffer buffer, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
DataBuffer	ByteArrayEncoder.encodeValue(byte[] bytes, DataBufferFactory bufferFactory, ResolvableType valueType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
DataBuffer	ByteBufferEncoder.encodeValue(ByteBuffer byteBuffer, DataBufferFactory bufferFactory, ResolvableType valueType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
DataBuffer	CharSequenceEncoder.encodeValue(CharSequence charSequence, DataBufferFactory bufferFactory, ResolvableType valueType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
DataBuffer	DataBufferEncoder.encodeValue(DataBuffer buffer, DataBufferFactory bufferFactory, ResolvableType valueType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
default DataBuffer	Encoder.encodeValue(T value, DataBufferFactory bufferFactory, ResolvableType valueType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Encode an Object of type T to a data buffer.
DataBuffer	NettyByteBufEncoder.encodeValue(io.netty.buffer.ByteBuf byteBuf, DataBufferFactory bufferFactory, ResolvableType valueType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)

Methods in org.springframework.core.codec that return types with arguments of type DataBuffer

Modifier and Type	Method	Description
Flux<DataBuffer>	DataBufferDecoder.decode(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
final Flux<DataBuffer>	AbstractSingleValueEncoder.encode(Publisher<? extends T> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
protected abstract Flux<DataBuffer>	AbstractSingleValueEncoder.encode(T t, DataBufferFactory dataBufferFactory, ResolvableType type, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Encode T to an output DataBuffer stream.
Flux<DataBuffer>	ByteArrayEncoder.encode(Publisher<? extends byte[]> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Flux<DataBuffer>	ByteBufferEncoder.encode(Publisher<? extends ByteBuffer> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Flux<DataBuffer>	CharSequenceEncoder.encode(Publisher<? extends CharSequence> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Flux<DataBuffer>	DataBufferEncoder.encode(Publisher<? extends DataBuffer> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Flux<DataBuffer>	Encoder.encode(Publisher<? extends T> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Encode a stream of Objects of type T into a DataBuffer output stream.
Flux<DataBuffer>	NettyByteBufEncoder.encode(Publisher<? extends io.netty.buffer.ByteBuf> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
protected Flux<DataBuffer>	ResourceEncoder.encode(Resource resource, DataBufferFactory bufferFactory, ResolvableType type, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Flux<DataBuffer>	ResourceRegionEncoder.encode(Publisher<? extends ResourceRegion> input, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)

Methods in org.springframework.core.codec with parameters of type DataBuffer

Modifier and Type	Method	Description
final T	AbstractCharSequenceDecoder.decode(DataBuffer dataBuffer, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
byte[]	ByteArrayDecoder.decode(DataBuffer dataBuffer, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
ByteBuffer	ByteBufferDecoder.decode(DataBuffer dataBuffer, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
DataBuffer	DataBufferDecoder.decode(DataBuffer buffer, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
default @Nullable T	Decoder.decode(DataBuffer buffer, ResolvableType targetType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Decode a data buffer to an Object of type T.
io.netty.buffer.ByteBuf	NettyByteBufDecoder.decode(DataBuffer dataBuffer, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Resource	ResourceDecoder.decode(DataBuffer dataBuffer, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
protected @Nullable T	AbstractDataBufferDecoder.decodeDataBuffer(DataBuffer buffer, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Deprecated. in favor of implementing Decoder.decode(DataBuffer, ResolvableType, MimeType, Map) instead
protected abstract T	AbstractCharSequenceDecoder.decodeInternal(DataBuffer dataBuffer, Charset charset)	Template method that decodes the given data buffer into T, given the charset.
protected CharBuffer	CharBufferDecoder.decodeInternal(DataBuffer dataBuffer, Charset charset)
protected String	StringDecoder.decodeInternal(DataBuffer dataBuffer, Charset charset)
DataBuffer	DataBufferEncoder.encodeValue(DataBuffer buffer, DataBufferFactory bufferFactory, ResolvableType valueType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
static void	Hints.touchDataBuffer(DataBuffer buffer, @Nullable Map<String,Object> hints, org.apache.commons.logging.Log logger)	If the hints contain a Hints.LOG_PREFIX_HINT and the given logger has DEBUG level enabled, apply the log prefix as a hint to the given buffer via DataBufferUtils.touch(DataBuffer, Object).

Method parameters in org.springframework.core.codec with type arguments of type DataBuffer

Modifier and Type	Method	Description
final Flux<T>	AbstractCharSequenceDecoder.decode(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Flux<T>	AbstractDataBufferDecoder.decode(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Flux<DataBuffer>	DataBufferDecoder.decode(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Flux<T>	Decoder.decode(Publisher<DataBuffer> inputStream, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Decode a DataBuffer input stream into a Flux of T.
Flux<Resource>	ResourceDecoder.decode(Publisher<DataBuffer> inputStream, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Mono<T>	AbstractDataBufferDecoder.decodeToMono(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Mono<T>	AbstractDecoder.decodeToMono(Publisher<DataBuffer> inputStream, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Mono<T>	Decoder.decodeToMono(Publisher<DataBuffer> inputStream, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Decode a DataBuffer input stream into a Mono of T.
Flux<DataBuffer>	DataBufferEncoder.encode(Publisher<? extends DataBuffer> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)

Uses of DataBuffer in org.springframework.core.io.buffer

Subinterfaces of DataBuffer in org.springframework.core.io.buffer

Modifier and Type	Interface	Description
interface	CloseableDataBuffer	Extension of DataBuffer that allows for buffers that can be used in a try-with-resources statement.
interface	PooledDataBuffer	Extension of DataBuffer that allows for buffers that share a memory pool.
interface	TouchableDataBuffer	Extension of DataBuffer that allows for buffers that can be given hints for debugging purposes.

Classes in org.springframework.core.io.buffer that implement DataBuffer

Modifier and Type	Class	Description
class	DataBufferWrapper	Provides a convenient implementation of the DataBuffer interface that can be overridden to adapt the delegate.
class	DefaultDataBuffer	Default implementation of the DataBuffer interface that uses a ByteBuffer internally.
final class	JettyDataBuffer	Implementation of the DataBuffer interface that can wrap a Jetty Content.Chunk.
class	NettyDataBuffer	Implementation of the DataBuffer interface that wraps a Netty 4 ByteBuf.

Subclasses with type arguments of type DataBuffer in org.springframework.core.io.buffer

Modifier and Type	Class	Description
class	LimitedDataBufferList	Custom List to collect data buffers with and enforce a limit on the total number of bytes buffered.

Methods in org.springframework.core.io.buffer with type parameters of type DataBuffer

Modifier and Type	Method	Description
static <T extends DataBuffer> T	DataBufferUtils.retain(T dataBuffer)	Retain the given data buffer, if it is a PooledDataBuffer.
static <T extends DataBuffer> Flux<T>	DataBufferUtils.skipUntilByteCount(Publisher<T> publisher, long maxByteCount)	Skip buffers from the given Publisher until the total byte count reaches the given maximum byte count, or until the publisher is complete.
static <T extends DataBuffer> InputStream	DataBufferUtils.subscriberInputStream(Publisher<T> publisher, int demand)	Subscribe to given Publisher of DataBuffers, and return an InputStream to consume the byte content with.
static <T extends DataBuffer> Flux<T>	DataBufferUtils.takeUntilByteCount(Publisher<T> publisher, long maxByteCount)	Relay buffers from the given Publisher until the total byte count reaches the given maximum byte count, or until the publisher is complete.
static <T extends DataBuffer> T	DataBufferUtils.touch(T dataBuffer, Object hint)	Associate the given hint with the data buffer if it is a pooled buffer and supports leak tracking.

Methods in org.springframework.core.io.buffer that return DataBuffer

Modifier and Type	Method	Description
DataBuffer	DataBufferFactory.allocateBuffer()	Deprecated. as of 6.0, in favor of DataBufferFactory.allocateBuffer(int)
DataBuffer	DataBufferFactory.allocateBuffer(int initialCapacity)	Allocate a data buffer of the given initial capacity.
DataBuffer	DataBuffer.capacity(int capacity)	Deprecated. as of 6.0, in favor of DataBuffer.ensureWritable(int) which has different semantics
DataBuffer	DataBufferWrapper.capacity(int capacity)	Deprecated.
DataBuffer	DefaultDataBuffer.capacity(int capacity)	Deprecated.
DataBuffer	JettyDataBuffer.capacity(int capacity)	Deprecated.
DataBuffer	DataBufferWrapper.dataBuffer()	Return the wrapped delegate.
default DataBuffer	DataBuffer.ensureCapacity(int capacity)	Deprecated. since 6.0, in favor of DataBuffer.ensureWritable(int)
DataBuffer	DataBufferWrapper.ensureCapacity(int capacity)	Deprecated.
DataBuffer	DataBuffer.ensureWritable(int capacity)	Ensure that the current buffer has enough DataBuffer.writableByteCount() to write the amount of data given as an argument.
DataBuffer	DataBufferWrapper.ensureWritable(int capacity)
DataBuffer	DefaultDataBuffer.ensureWritable(int length)
DataBuffer	JettyDataBuffer.ensureWritable(int capacity)
DataBuffer	NettyDataBuffer.ensureWritable(int capacity)
DataBuffer	DataBufferFactory.join(List<? extends DataBuffer> dataBuffers)	Return a new DataBuffer composed of the dataBuffers elements joined together.
DataBuffer	NettyDataBufferFactory.join(List<? extends DataBuffer> dataBuffers)	Return a new DataBuffer composed of the dataBuffers elements joined together.
DataBuffer	DataBuffer.read(byte[] destination)	Read this buffer's data into the specified destination, starting at the current reading position of this buffer.
DataBuffer	DataBuffer.read(byte[] destination, int offset, int length)	Read at most length bytes of this buffer into the specified destination, starting at the current reading position of this buffer.
DataBuffer	DataBufferWrapper.read(byte[] destination)
DataBuffer	DataBufferWrapper.read(byte[] destination, int offset, int length)
DataBuffer	JettyDataBuffer.read(byte[] destination)
DataBuffer	JettyDataBuffer.read(byte[] destination, int offset, int length)
DataBuffer	DataBuffer.readPosition(int readPosition)	Set the position from which this buffer will read.
DataBuffer	DataBufferWrapper.readPosition(int readPosition)
DataBuffer	JettyDataBuffer.readPosition(int readPosition)
DataBuffer	LimitedDataBufferList.remove(int index)
default DataBuffer	DataBuffer.retainedSlice(int index, int length)	Deprecated. as of 6.0, in favor of DataBuffer.split(int) which has different semantics
DataBuffer	DataBufferWrapper.retainedSlice(int index, int length)	Deprecated.
DataBuffer	LimitedDataBufferList.set(int index, DataBuffer element)
DataBuffer	DataBuffer.slice(int index, int length)	Deprecated. as of 6.0, in favor of DataBuffer.split(int) which has different semantics
DataBuffer	DataBufferWrapper.slice(int index, int length)	Deprecated.
DataBuffer	JettyDataBuffer.slice(int index, int length)	Deprecated.
DataBuffer	DataBuffer.split(int index)	Splits this data buffer into two at the given index.
DataBuffer	DataBufferWrapper.split(int index)
DataBuffer	JettyDataBuffer.split(int index)
DataBuffer	DataBufferFactory.wrap(byte[] bytes)	Wrap the given byte array in a DataBuffer.
DataBuffer	DataBufferFactory.wrap(ByteBuffer byteBuffer)	Wrap the given ByteBuffer in a DataBuffer.
DataBuffer	NettyDataBufferFactory.wrap(byte[] bytes)
DataBuffer	DataBuffer.write(byte b)	Write a single byte into this buffer at the current writing position.
DataBuffer	DataBuffer.write(byte[] source)	Write the given source into this buffer, starting at the current writing position of this buffer.
DataBuffer	DataBuffer.write(byte[] source, int offset, int length)	Write at most length bytes of the given source into this buffer, starting at the current writing position of this buffer.
default DataBuffer	DataBuffer.write(CharSequence charSequence, Charset charset)	Write the given CharSequence using the given Charset, starting at the current writing position.
DataBuffer	DataBuffer.write(ByteBuffer... buffers)	Write one or more ByteBuffer to this buffer, starting at the current writing position.
DataBuffer	DataBuffer.write(DataBuffer... buffers)	Write one or more DataBuffers to this buffer, starting at the current writing position.
DataBuffer	DataBufferWrapper.write(byte b)
DataBuffer	DataBufferWrapper.write(byte[] source)
DataBuffer	DataBufferWrapper.write(byte[] source, int offset, int length)
DataBuffer	DataBufferWrapper.write(CharSequence charSequence, Charset charset)
DataBuffer	DataBufferWrapper.write(ByteBuffer... buffers)
DataBuffer	DataBufferWrapper.write(DataBuffer... buffers)
DataBuffer	JettyDataBuffer.write(byte b)
DataBuffer	JettyDataBuffer.write(byte[] source)
DataBuffer	JettyDataBuffer.write(byte[] source, int offset, int length)
DataBuffer	JettyDataBuffer.write(ByteBuffer... buffers)
DataBuffer	JettyDataBuffer.write(DataBuffer... buffers)
DataBuffer	NettyDataBuffer.write(CharSequence charSequence, Charset charset)
DataBuffer	DataBuffer.writePosition(int writePosition)	Set the position to which this buffer will write.
DataBuffer	DataBufferWrapper.writePosition(int writePosition)
DataBuffer	JettyDataBuffer.writePosition(int writePosition)

Methods in org.springframework.core.io.buffer that return types with arguments of type DataBuffer

Modifier and Type	Method	Description
static Mono<DataBuffer>	DataBufferUtils.join(Publisher<? extends DataBuffer> dataBuffers)	Return a new DataBuffer composed of joining together the given dataBuffers elements.
static Mono<DataBuffer>	DataBufferUtils.join(Publisher<? extends DataBuffer> buffers, int maxByteCount)	Variant of DataBufferUtils.join(Publisher) that behaves the same way up until the specified max number of bytes to buffer.
static Publisher<DataBuffer>	DataBufferUtils.outputStreamPublisher(Consumer<OutputStream> consumer, DataBufferFactory bufferFactory, Executor executor)	Create a new Publisher<DataBuffer> based on bytes written to a OutputStream.
static Publisher<DataBuffer>	DataBufferUtils.outputStreamPublisher(Consumer<OutputStream> consumer, DataBufferFactory bufferFactory, Executor executor, int chunkSize)	Variant of DataBufferUtils.outputStreamPublisher(Consumer, DataBufferFactory, Executor) providing control over the chunk sizes to be produced by the publisher.
static Flux<DataBuffer>	DataBufferUtils.read(Path path, DataBufferFactory bufferFactory, int bufferSize, OpenOption... options)	Read bytes from the given file Path into a Flux of DataBuffers.
static Flux<DataBuffer>	DataBufferUtils.read(Resource resource, long position, DataBufferFactory bufferFactory, int bufferSize)	Read the given Resource into a Flux of DataBuffers starting at the given position.
static Flux<DataBuffer>	DataBufferUtils.read(Resource resource, DataBufferFactory bufferFactory, int bufferSize)	Read the given Resource into a Flux of DataBuffers.
static Flux<DataBuffer>	DataBufferUtils.readAsynchronousFileChannel(Callable<AsynchronousFileChannel> channelSupplier, long position, DataBufferFactory bufferFactory, int bufferSize)	Obtain an AsynchronousFileChannel from the given supplier, and read it into a Flux of DataBuffers, starting at the given position.
static 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 DataBuffers.
static Flux<DataBuffer>	DataBufferUtils.readByteChannel(Callable<ReadableByteChannel> channelSupplier, DataBufferFactory bufferFactory, int bufferSize)	Obtain a ReadableByteChannel from the given supplier, and read it into a Flux of DataBuffers.
static Flux<DataBuffer>	DataBufferUtils.readInputStream(Callable<InputStream> inputStreamSupplier, DataBufferFactory bufferFactory, int bufferSize)	Obtain an InputStream from the given supplier, and read it into a Flux of DataBuffers.
static Consumer<DataBuffer>	DataBufferUtils.releaseConsumer()	Return a consumer that calls DataBufferUtils.release(DataBuffer) on all passed data buffers.
static Flux<DataBuffer>	DataBufferUtils.write(Publisher<? extends DataBuffer> source, AsynchronousFileChannel channel, long position)	Write the given stream of DataBuffers to the given AsynchronousFileChannel.
static Flux<DataBuffer>	DataBufferUtils.write(Publisher<DataBuffer> source, OutputStream outputStream)	Write the given stream of DataBuffers to the given OutputStream.
static Flux<DataBuffer>	DataBufferUtils.write(Publisher<DataBuffer> source, AsynchronousFileChannel channel)	Write the given stream of DataBuffers to the given AsynchronousFileChannel.
static Flux<DataBuffer>	DataBufferUtils.write(Publisher<DataBuffer> source, WritableByteChannel channel)	Write the given stream of DataBuffers to the given WritableByteChannel.

Methods in org.springframework.core.io.buffer with parameters of type DataBuffer

Modifier and Type	Method	Description
void	LimitedDataBufferList.add(int index, DataBuffer buffer)
boolean	LimitedDataBufferList.add(DataBuffer buffer)
int	DataBufferUtils.Matcher.match(DataBuffer dataBuffer)	Find the first matching delimiter and return the index of the last byte of the delimiter, or -1 if not found.
static boolean	DataBufferUtils.release(@Nullable DataBuffer dataBuffer)	Release the given data buffer.
DataBuffer	LimitedDataBufferList.set(int index, DataBuffer element)
static io.netty.buffer.ByteBuf	NettyDataBufferFactory.toByteBuf(DataBuffer dataBuffer)	Return the given Netty DataBuffer as a ByteBuf.
DataBuffer	DataBuffer.write(DataBuffer... buffers)	Write one or more DataBuffers to this buffer, starting at the current writing position.
DataBuffer	DataBufferWrapper.write(DataBuffer... buffers)
DefaultDataBuffer	DefaultDataBuffer.write(DataBuffer... dataBuffers)
DataBuffer	JettyDataBuffer.write(DataBuffer... buffers)
NettyDataBuffer	NettyDataBuffer.write(DataBuffer... dataBuffers)

Method parameters in org.springframework.core.io.buffer with type arguments of type DataBuffer

Modifier and Type	Method	Description
boolean	LimitedDataBufferList.addAll(int index, Collection<? extends DataBuffer> collection)
boolean	LimitedDataBufferList.addAll(Collection<? extends DataBuffer> collection)
DataBuffer	DataBufferFactory.join(List<? extends DataBuffer> dataBuffers)	Return a new DataBuffer composed of the dataBuffers elements joined together.
static Mono<DataBuffer>	DataBufferUtils.join(Publisher<? extends DataBuffer> dataBuffers)	Return a new DataBuffer composed of joining together the given dataBuffers elements.
static Mono<DataBuffer>	DataBufferUtils.join(Publisher<? extends DataBuffer> buffers, int maxByteCount)	Variant of DataBufferUtils.join(Publisher) that behaves the same way up until the specified max number of bytes to buffer.
DefaultDataBuffer	DefaultDataBufferFactory.join(List<? extends DataBuffer> dataBuffers)	Return a new DataBuffer composed of the dataBuffers elements joined together.
JettyDataBuffer	JettyDataBufferFactory.join(List<? extends DataBuffer> dataBuffers)
DataBuffer	NettyDataBufferFactory.join(List<? extends DataBuffer> dataBuffers)	Return a new DataBuffer composed of the dataBuffers elements joined together.
boolean	LimitedDataBufferList.removeIf(Predicate<? super DataBuffer> filter)
static Flux<DataBuffer>	DataBufferUtils.write(Publisher<? extends DataBuffer> source, AsynchronousFileChannel channel, long position)	Write the given stream of DataBuffers to the given AsynchronousFileChannel.
static Flux<DataBuffer>	DataBufferUtils.write(Publisher<DataBuffer> source, OutputStream outputStream)	Write the given stream of DataBuffers to the given OutputStream.
static Flux<DataBuffer>	DataBufferUtils.write(Publisher<DataBuffer> source, AsynchronousFileChannel channel)	Write the given stream of DataBuffers to the given AsynchronousFileChannel.
static Flux<DataBuffer>	DataBufferUtils.write(Publisher<DataBuffer> source, WritableByteChannel channel)	Write the given stream of DataBuffers to the given WritableByteChannel.
static Mono<Void>	DataBufferUtils.write(Publisher<DataBuffer> source, Path destination, OpenOption... options)	Write the given stream of DataBuffers to the given file Path.

Constructors in org.springframework.core.io.buffer with parameters of type DataBuffer

Modifier	Constructor	Description
	DataBufferWrapper(DataBuffer delegate)	Create a new DataBufferWrapper that wraps the given buffer.

Uses of DataBuffer in org.springframework.http

Methods in org.springframework.http that return types with arguments of type DataBuffer

Modifier and Type	Method	Description
Flux<DataBuffer>	ReactiveHttpInputMessage.getBody()	Return the body of the message as a Publisher.

Method parameters in org.springframework.http with type arguments of type DataBuffer

Modifier and Type	Method	Description
Mono<Void>	ReactiveHttpOutputMessage.writeAndFlushWith(Publisher<? extends Publisher<? extends DataBuffer>> body)	Use the given Publisher of Publishers to write the body of the HttpOutputMessage to the underlying HTTP layer, flushing after each Publisher<DataBuffer>.
Mono<Void>	ReactiveHttpOutputMessage.writeWith(Publisher<? extends DataBuffer> body)	Use the given Publisher to write the body of the message to the underlying HTTP layer.

Uses of DataBuffer in org.springframework.http.client.reactive

Methods in org.springframework.http.client.reactive that return types with arguments of type DataBuffer

Modifier and Type	Method	Description
Flux<DataBuffer>	AbstractClientHttpResponse.getBody()
Flux<DataBuffer>	ClientHttpResponseDecorator.getBody()

Method parameters in org.springframework.http.client.reactive with type arguments of type DataBuffer

Modifier and Type	Method	Description
Mono<Void>	ClientHttpRequestDecorator.writeAndFlushWith(Publisher<? extends Publisher<? extends DataBuffer>> body)
Mono<Void>	ClientHttpRequestDecorator.writeWith(Publisher<? extends DataBuffer> body)

Constructor parameters in org.springframework.http.client.reactive with type arguments of type DataBuffer

Modifier	Constructor	Description
protected	AbstractClientHttpResponse(HttpStatusCode statusCode, HttpHeaders headers, MultiValueMap<String, ResponseCookie> cookies, Flux<DataBuffer> body)

Uses of DataBuffer in org.springframework.http.codec

Methods in org.springframework.http.codec that return DataBuffer

Modifier and Type	Method	Description
protected DataBuffer	KotlinSerializationStringEncoder.encodeStreamingValue(Object value, DataBufferFactory bufferFactory, ResolvableType valueType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints, byte[] prefix, byte[] suffix)
DataBuffer	AbstractJacksonEncoder.encodeValue(Object value, DataBufferFactory bufferFactory, ResolvableType valueType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
DataBuffer	KotlinSerializationBinaryEncoder.encodeValue(Object value, DataBufferFactory bufferFactory, ResolvableType valueType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
DataBuffer	KotlinSerializationStringEncoder.encodeValue(Object value, DataBufferFactory bufferFactory, ResolvableType valueType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)

Methods in org.springframework.http.codec that return types with arguments of type DataBuffer

Modifier and Type	Method	Description
Flux<DataBuffer>	AbstractJacksonEncoder.encode(Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Flux<DataBuffer>	KotlinSerializationBinaryEncoder.encode(Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Flux<DataBuffer>	KotlinSerializationStringEncoder.encode(Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
protected Flux<DataBuffer>	KotlinSerializationStringEncoder.encodeNonStream(Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
protected Flux<DataBuffer>	AbstractJacksonDecoder.processInput(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Process the input publisher into a flux.

Methods in org.springframework.http.codec with parameters of type DataBuffer

Modifier and Type	Method	Description
Object	AbstractJacksonDecoder.decode(DataBuffer dataBuffer, ResolvableType targetType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)

Method parameters in org.springframework.http.codec with type arguments of type DataBuffer

Modifier and Type	Method	Description
Flux<Object>	AbstractJacksonDecoder.decode(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Flux<Object>	KotlinSerializationBinaryDecoder.decode(Publisher<DataBuffer> inputStream, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Flux<Object>	KotlinSerializationStringDecoder.decode(Publisher<DataBuffer> inputStream, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Mono<Object>	AbstractJacksonDecoder.decodeToMono(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Mono<Object>	KotlinSerializationBinaryDecoder.decodeToMono(Publisher<DataBuffer> inputStream, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Mono<Object>	KotlinSerializationStringDecoder.decodeToMono(Publisher<DataBuffer> inputStream, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
protected Flux<DataBuffer>	AbstractJacksonDecoder.processInput(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Process the input publisher into a flux.

Uses of DataBuffer in org.springframework.http.codec.cbor

Methods in org.springframework.http.codec.cbor that return types with arguments of type DataBuffer

Modifier and Type	Method	Description
Flux<DataBuffer>	Jackson2CborEncoder.encode(Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Deprecated, for removal: This API element is subject to removal in a future version.
Flux<DataBuffer>	JacksonCborEncoder.encode(Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)

Method parameters in org.springframework.http.codec.cbor with type arguments of type DataBuffer

Modifier and Type	Method	Description
Flux<Object>	Jackson2CborDecoder.decode(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Deprecated, for removal: This API element is subject to removal in a future version.
Flux<Object>	JacksonCborDecoder.decode(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)

Uses of DataBuffer in org.springframework.http.codec.json

Methods in org.springframework.http.codec.json that return DataBuffer

Modifier and Type	Method	Description
DataBuffer	AbstractJackson2Encoder.encodeValue(Object value, DataBufferFactory bufferFactory, ResolvableType valueType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Deprecated, for removal: This API element is subject to removal in a future version.
DataBuffer	GsonEncoder.encodeValue(Object value, DataBufferFactory bufferFactory, ResolvableType valueType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)

Methods in org.springframework.http.codec.json that return types with arguments of type DataBuffer

Modifier and Type	Method	Description
Flux<DataBuffer>	AbstractJackson2Encoder.encode(Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Deprecated, for removal: This API element is subject to removal in a future version.
Flux<DataBuffer>	GsonEncoder.encode(Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Flux<DataBuffer>	KotlinSerializationJsonEncoder.encodeNonStream(Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
protected Flux<DataBuffer>	AbstractJackson2Decoder.processInput(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Deprecated, for removal: This API element is subject to removal in a future version. Process the input publisher into a flux.
protected Flux<DataBuffer>	Jackson2JsonDecoder.processInput(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Deprecated, for removal: This API element is subject to removal in a future version.
protected Flux<DataBuffer>	JacksonJsonDecoder.processInput(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)

Methods in org.springframework.http.codec.json with parameters of type DataBuffer

Modifier and Type	Method	Description
Object	AbstractJackson2Decoder.decode(DataBuffer dataBuffer, ResolvableType targetType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Deprecated, for removal: This API element is subject to removal in a future version.
@Nullable Object	GsonDecoder.decode(DataBuffer buffer, ResolvableType targetType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)

Method parameters in org.springframework.http.codec.json with type arguments of type DataBuffer

Modifier and Type	Method	Description
Flux<Object>	AbstractJackson2Decoder.decode(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Deprecated, for removal: This API element is subject to removal in a future version.
Flux<Object>	GsonDecoder.decode(Publisher<DataBuffer> inputStream, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Flux<Object>	KotlinSerializationJsonDecoder.decode(Publisher<DataBuffer> inputStream, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Mono<Object>	AbstractJackson2Decoder.decodeToMono(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Deprecated, for removal: This API element is subject to removal in a future version.
protected Flux<DataBuffer>	AbstractJackson2Decoder.processInput(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Deprecated, for removal: This API element is subject to removal in a future version. Process the input publisher into a flux.
protected Flux<DataBuffer>	Jackson2JsonDecoder.processInput(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)	Deprecated, for removal: This API element is subject to removal in a future version.
protected Flux<DataBuffer>	JacksonJsonDecoder.processInput(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)

Uses of DataBuffer in org.springframework.http.codec.multipart

Methods in org.springframework.http.codec.multipart that return DataBuffer

Modifier and Type	Method	Description
DataBuffer	PartEvent.content()	Return the content of this event.

Methods in org.springframework.http.codec.multipart that return types with arguments of type DataBuffer

Modifier and Type	Method	Description
Flux<DataBuffer>	Part.content()	Return the content for this part.
protected Mono<DataBuffer>	MultipartWriterSupport.generateBoundaryLine(byte[] boundary, DataBufferFactory bufferFactory)
protected Mono<DataBuffer>	MultipartWriterSupport.generateLastLine(byte[] boundary, DataBufferFactory bufferFactory)
protected Mono<DataBuffer>	MultipartWriterSupport.generateNewLine(DataBufferFactory bufferFactory)
protected Mono<DataBuffer>	MultipartWriterSupport.generatePartHeaders(HttpHeaders headers, DataBufferFactory bufferFactory)

Method parameters in org.springframework.http.codec.multipart with type arguments of type DataBuffer

Modifier and Type	Method	Description
static Flux<FilePartEvent>	FilePartEvent.create(String partName, String filename, MediaType contentType, Flux<DataBuffer> contents)	Creates a stream of FilePartEvent objects based on the given name, FilePartEvent.filename(), content-type, and contents.
static Flux<FilePartEvent>	FilePartEvent.create(String partName, String filename, MediaType contentType, Flux<DataBuffer> contents, @Nullable Consumer<HttpHeaders> headersConsumer)	Creates a stream of FilePartEvent objects based on the given name, FilePartEvent.filename(), content-type, and contents.

Uses of DataBuffer in org.springframework.http.codec.protobuf

Methods in org.springframework.http.codec.protobuf that return DataBuffer

Modifier and Type	Method	Description
DataBuffer	ProtobufEncoder.encodeValue(com.google.protobuf.Message message, DataBufferFactory bufferFactory, ResolvableType valueType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
DataBuffer	ProtobufJsonEncoder.encodeValue(com.google.protobuf.Message message, DataBufferFactory bufferFactory, ResolvableType valueType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)

Methods in org.springframework.http.codec.protobuf that return types with arguments of type DataBuffer

Modifier and Type	Method	Description
Flux<DataBuffer>	ProtobufEncoder.encode(Publisher<? extends com.google.protobuf.Message> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Flux<DataBuffer>	ProtobufJsonEncoder.encode(Publisher<? extends com.google.protobuf.Message> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)

Methods in org.springframework.http.codec.protobuf with parameters of type DataBuffer

Modifier and Type	Method	Description
com.google.protobuf.Message	ProtobufDecoder.decode(DataBuffer dataBuffer, ResolvableType targetType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
com.google.protobuf.Message	ProtobufJsonDecoder.decode(DataBuffer dataBuffer, ResolvableType targetType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
protected void	ProtobufDecoder.merge(DataBuffer dataBuffer, com.google.protobuf.Message.Builder builder)	Use merge methods on Message.Builder to read a single message from the given DataBuffer.
@Nullable Integer	ProtobufDecoder.MessageSizeReader.readMessageSize(DataBuffer input)	Read the message size from the given buffer.

Method parameters in org.springframework.http.codec.protobuf with type arguments of type DataBuffer

Modifier and Type	Method	Description
Flux<com.google.protobuf.Message>	ProtobufDecoder.decode(Publisher<DataBuffer> inputStream, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Flux<com.google.protobuf.Message>	ProtobufJsonDecoder.decode(Publisher<DataBuffer> inputStream, ResolvableType targetType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Mono<com.google.protobuf.Message>	ProtobufDecoder.decodeToMono(Publisher<DataBuffer> inputStream, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Mono<com.google.protobuf.Message>	ProtobufJsonDecoder.decodeToMono(Publisher<DataBuffer> inputStream, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)

Uses of DataBuffer in org.springframework.http.codec.xml

Methods in org.springframework.http.codec.xml that return DataBuffer

Modifier and Type	Method	Description
DataBuffer	Jaxb2XmlEncoder.encodeValue(Object value, DataBufferFactory bufferFactory, ResolvableType valueType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)

Methods in org.springframework.http.codec.xml that return types with arguments of type DataBuffer

Modifier and Type	Method	Description
Flux<DataBuffer>	JacksonXmlEncoder.encode(Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
protected Flux<DataBuffer>	Jaxb2XmlEncoder.encode(Object value, DataBufferFactory bufferFactory, ResolvableType valueType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)

Methods in org.springframework.http.codec.xml with parameters of type DataBuffer

Modifier and Type	Method	Description
Object	Jaxb2XmlDecoder.decode(DataBuffer dataBuffer, ResolvableType targetType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)

Method parameters in org.springframework.http.codec.xml with type arguments of type DataBuffer

Modifier and Type	Method	Description
Flux<Object>	JacksonXmlDecoder.decode(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Flux<Object>	Jaxb2XmlDecoder.decode(Publisher<DataBuffer> inputStream, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Flux<XMLEvent>	XmlEventDecoder.decode(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)
Mono<Object>	Jaxb2XmlDecoder.decodeToMono(Publisher<DataBuffer> input, ResolvableType elementType, @Nullable MimeType mimeType, @Nullable Map<String,Object> hints)

Uses of DataBuffer in org.springframework.http.server.reactive

Methods in org.springframework.http.server.reactive that return types with arguments of type DataBuffer

Modifier and Type	Method	Description
protected abstract Processor<? super Publisher<? extends DataBuffer>, Void>	AbstractListenerServerHttpResponse.createBodyFlushProcessor()	Abstract template method to create a Processor<Publisher<DataBuffer>, Void> that will write the response body with flushes to the underlying output.
Flux<DataBuffer>	ServerHttpRequestDecorator.getBody()

Methods in org.springframework.http.server.reactive with parameters of type DataBuffer

Modifier and Type	Method	Description
protected void	AbstractServerHttpResponse.touchDataBuffer(DataBuffer buffer)	Allow subclasses to associate a hint with the data buffer if it is a pooled buffer and supports leak tracking.

Method parameters in org.springframework.http.server.reactive with type arguments of type DataBuffer

Modifier and Type	Method	Description
final Mono<Void>	AbstractServerHttpResponse.writeAndFlushWith(Publisher<? extends Publisher<? extends DataBuffer>> body)
final Mono<Void>	HttpHeadResponseDecorator.writeAndFlushWith(Publisher<? extends Publisher<? extends DataBuffer>> body)	Invoke ServerHttpResponseDecorator.setComplete() without writing.
Mono<Void>	ServerHttpResponseDecorator.writeAndFlushWith(Publisher<? extends Publisher<? extends DataBuffer>> body)
protected final Mono<Void>	AbstractListenerServerHttpResponse.writeAndFlushWithInternal(Publisher<? extends Publisher<? extends DataBuffer>> body)
protected abstract Mono<Void>	AbstractServerHttpResponse.writeAndFlushWithInternal(Publisher<? extends Publisher<? extends DataBuffer>> body)	Write to the underlying the response, and flush after each Publisher<DataBuffer>.
final Mono<Void>	AbstractServerHttpResponse.writeWith(Publisher<? extends DataBuffer> body)
final Mono<Void>	HttpHeadResponseDecorator.writeWith(Publisher<? extends DataBuffer> body)	Consume and release the body without writing.
Mono<Void>	ServerHttpResponseDecorator.writeWith(Publisher<? extends DataBuffer> body)
protected final Mono<Void>	AbstractListenerServerHttpResponse.writeWithInternal(Publisher<? extends DataBuffer> body)
protected abstract Mono<Void>	AbstractServerHttpResponse.writeWithInternal(Publisher<? extends DataBuffer> body)	Write to the underlying the response.

Uses of DataBuffer in org.springframework.messaging.handler.invocation.reactive

Method parameters in org.springframework.messaging.handler.invocation.reactive with type arguments of type DataBuffer

Modifier and Type	Method	Description
protected abstract Mono<Void>	AbstractEncoderMethodReturnValueHandler.handleEncodedContent(Flux<DataBuffer> encodedContent, MethodParameter returnType, Message<?> message)	Subclasses implement this method to handle encoded values in some way such as creating and sending messages.

Uses of DataBuffer in org.springframework.messaging.rsocket

Methods in org.springframework.messaging.rsocket that return DataBuffer

Modifier and Type	Method	Description
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.

Methods in org.springframework.messaging.rsocket with parameters of type DataBuffer

Modifier and Type	Method	Description
static io.rsocket.Payload	PayloadUtils.createPayload(DataBuffer data)	Create a Payload with data only.
static io.rsocket.Payload	PayloadUtils.createPayload(DataBuffer data, DataBuffer metadata)	Create a Payload from the given metadata and data.

Uses of DataBuffer in org.springframework.messaging.rsocket.annotation.support

Method parameters in org.springframework.messaging.rsocket.annotation.support with type arguments of type DataBuffer

Modifier and Type	Method	Description
protected Mono<Void>	RSocketPayloadReturnValueHandler.handleEncodedContent(Flux<DataBuffer> encodedContent, MethodParameter returnType, Message<?> message)

Uses of DataBuffer in org.springframework.mock.http.client.reactive

Methods in org.springframework.mock.http.client.reactive that return types with arguments of type DataBuffer

Modifier and Type	Method	Description
Flux<DataBuffer>	MockClientHttpRequest.getBody()	Return the request body, or an error stream if the body was never set or when MockClientHttpRequest.setWriteHandler(Function) is configured.
Flux<DataBuffer>	MockClientHttpResponse.getBody()

Method parameters in org.springframework.mock.http.client.reactive with type arguments of type DataBuffer

Modifier and Type	Method	Description
void	MockClientHttpResponse.setBody(Publisher<DataBuffer> body)
void	MockClientHttpRequest.setWriteHandler(Function<Flux<DataBuffer>, Mono<Void>> writeHandler)	Configure a custom handler for writing the request body.
Mono<Void>	MockClientHttpRequest.writeAndFlushWith(Publisher<? extends Publisher<? extends DataBuffer>> body)
Mono<Void>	MockClientHttpRequest.writeWith(Publisher<? extends DataBuffer> body)

Uses of DataBuffer in org.springframework.mock.http.server.reactive

Methods in org.springframework.mock.http.server.reactive that return types with arguments of type DataBuffer

Modifier and Type	Method	Description
Flux<DataBuffer>	MockServerHttpRequest.getBody()
Flux<DataBuffer>	MockServerHttpResponse.getBody()	Return the response body or an error stream if the body was not set.

Method parameters in org.springframework.mock.http.server.reactive with type arguments of type DataBuffer

Modifier and Type	Method	Description
MockServerHttpRequest	MockServerHttpRequest.BodyBuilder.body(Publisher<? extends DataBuffer> body)	Set the body of the request and build it.
void	MockServerHttpResponse.setWriteHandler(Function<Flux<DataBuffer>, Mono<Void>> writeHandler)	Configure a custom handler to consume the response body.
protected Mono<Void>	MockServerHttpResponse.writeAndFlushWithInternal(Publisher<? extends Publisher<? extends DataBuffer>> body)
protected Mono<Void>	MockServerHttpResponse.writeWithInternal(Publisher<? extends DataBuffer> body)

Uses of DataBuffer in org.springframework.web.reactive.function

Methods in org.springframework.web.reactive.function with type parameters of type DataBuffer

Modifier and Type	Method	Description
static <T extends Publisher<DataBuffer>> BodyInserter<T, ReactiveHttpOutputMessage>	BodyInserters.fromDataBuffers(T publisher)	Inserter to write the given Publisher<DataBuffer> to the body.
static <T extends Publisher<DataBuffer>> BodyInserter<T, ReactiveHttpOutputMessage>	BodyInserters.fromOutputStream(Consumer<OutputStream> outputStreamConsumer, Executor executor)	Inserter based on bytes written to a OutputStream.
static <T extends Publisher<DataBuffer>> BodyInserter<T, ReactiveHttpOutputMessage>	BodyInserters.fromOutputStream(Consumer<OutputStream> outputStreamConsumer, Executor executor, int chunkSize)	Inserter based on bytes written to a OutputStream.

Methods in org.springframework.web.reactive.function that return types with arguments of type DataBuffer

Modifier and Type	Method	Description
static BodyExtractor<Flux<DataBuffer>, ReactiveHttpInputMessage>	BodyExtractors.toDataBuffers()	Extractor that returns the raw DataBuffers.

Uses of DataBuffer in org.springframework.web.reactive.function.client

Method parameters in org.springframework.web.reactive.function.client with type arguments of type DataBuffer

Modifier and Type	Method	Description
ClientResponse.Builder	ClientResponse.Builder.body(Function<Flux<DataBuffer>, Flux<DataBuffer>> transformer)	Transform the response body, if set in the builder.
ClientResponse.Builder	ClientResponse.Builder.body(Function<Flux<DataBuffer>, Flux<DataBuffer>> transformer)	Transform the response body, if set in the builder.
ClientResponse.Builder	ClientResponse.Builder.body(Flux<DataBuffer> body)	Set the body of the response.

Uses of DataBuffer in org.springframework.web.reactive.function.server

Method parameters in org.springframework.web.reactive.function.server with type arguments of type DataBuffer

Modifier and Type	Method	Description
ServerRequest.Builder	ServerRequest.Builder.body(Flux<DataBuffer> body)	Set the body of the request.

Uses of DataBuffer in org.springframework.web.reactive.socket

Methods in org.springframework.web.reactive.socket that return DataBuffer

Modifier and Type	Method	Description
DataBuffer	WebSocketMessage.getPayload()	Return the message payload.

Method parameters in org.springframework.web.reactive.socket with type arguments of type DataBuffer

Modifier and Type	Method	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.

Constructors in org.springframework.web.reactive.socket with parameters of type DataBuffer

Modifier	Constructor	Description
	WebSocketMessage(WebSocketMessage.Type type, DataBuffer payload)	Constructor for a WebSocketMessage.
	WebSocketMessage(WebSocketMessage.Type type, DataBuffer payload, @Nullable Object nativeMessage)	Constructor for an inbound message with access to the underlying message.

Uses of DataBuffer in org.springframework.web.reactive.socket.adapter

Method parameters in org.springframework.web.reactive.socket.adapter with type arguments of type DataBuffer

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)