Uses of Interface
org.springframework.core.io.buffer.DataBuffer
Packages that use DataBuffer 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.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 aServerHttpRequest
andServerHttpResponse
along with anHttpHandler
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 reactiveWebClient
that builds on top of theorg.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
Methods in org.springframework.core.codec that return DataBuffer Modifier and Type Method Description DataBuffer
DataBufferDecoder. decode(DataBuffer buffer, 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.Methods in org.springframework.core.codec that return types with arguments of type DataBuffer Modifier and Type Method Description reactor.core.publisher.Flux<DataBuffer>
DataBufferDecoder. decode(org.reactivestreams.Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
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)
Methods in org.springframework.core.codec with parameters of type DataBuffer Modifier and Type Method Description byte[]
ByteArrayDecoder. decode(DataBuffer dataBuffer, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
ByteBuffer
ByteBufferDecoder. decode(DataBuffer dataBuffer, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
DataBuffer
DataBufferDecoder. decode(DataBuffer buffer, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
default T
Decoder. decode(DataBuffer buffer, ResolvableType targetType, MimeType mimeType, Map<String,Object> hints)
Decode a data buffer to an Object of type T.Resource
ResourceDecoder. decode(DataBuffer dataBuffer, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
String
StringDecoder. decode(DataBuffer dataBuffer, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
protected T
AbstractDataBufferDecoder. decodeDataBuffer(DataBuffer buffer, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
Deprecated.as of 5.2, please implementDecoder.decode(DataBuffer, ResolvableType, MimeType, Map)
insteadDataBuffer
DataBufferEncoder. encodeValue(DataBuffer buffer, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, Map<String,Object> hints)
Method parameters in org.springframework.core.codec with type arguments of type DataBuffer Modifier and Type Method Description reactor.core.publisher.Flux<T>
AbstractDataBufferDecoder. decode(org.reactivestreams.Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
reactor.core.publisher.Flux<DataBuffer>
DataBufferDecoder. decode(org.reactivestreams.Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
reactor.core.publisher.Flux<T>
Decoder. decode(org.reactivestreams.Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
Decode aDataBuffer
input stream into a Flux ofT
.reactor.core.publisher.Flux<Resource>
ResourceDecoder. decode(org.reactivestreams.Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
reactor.core.publisher.Flux<String>
StringDecoder. decode(org.reactivestreams.Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
reactor.core.publisher.Mono<T>
AbstractDataBufferDecoder. decodeToMono(org.reactivestreams.Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
reactor.core.publisher.Mono<T>
AbstractDecoder. decodeToMono(org.reactivestreams.Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
reactor.core.publisher.Mono<T>
Decoder. decodeToMono(org.reactivestreams.Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
Decode aDataBuffer
input stream into a Mono ofT
.reactor.core.publisher.Flux<DataBuffer>
DataBufferEncoder. encode(org.reactivestreams.Publisher<? extends DataBuffer> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, 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
PooledDataBuffer
Extension ofDataBuffer
that allows for buffer that share a memory pool.Classes in org.springframework.core.io.buffer that implement DataBuffer Modifier and Type Class Description class
DataBufferWrapper
Provides a convenient implementation of theDataBuffer
interface that can be overridden to adapt the delegate.class
DefaultDataBuffer
Default implementation of theDataBuffer
interface that uses aByteBuffer
internally.class
NettyDataBuffer
Implementation of theDataBuffer
interface that wraps a NettyByteBuf
.Methods in org.springframework.core.io.buffer with type parameters of type DataBuffer Modifier and Type Method Description static <T extends DataBuffer>
TDataBufferUtils. retain(T dataBuffer)
Retain the given data buffer, if it is aPooledDataBuffer
.Methods in org.springframework.core.io.buffer that return DataBuffer Modifier and Type Method Description DataBuffer
DataBufferFactory. allocateBuffer()
Allocate a data buffer of a default initial capacity.DataBuffer
DataBufferFactory. allocateBuffer(int initialCapacity)
Allocate a data buffer of the given initial capacity.DataBuffer
DataBuffer. capacity(int capacity)
Set the number of bytes that this buffer can contain.DataBuffer
DataBufferWrapper. capacity(int capacity)
DataBuffer
DataBufferWrapper. dataBuffer()
Return the wrapped delegate.default DataBuffer
DataBuffer. ensureCapacity(int capacity)
Ensure that the current buffer has enoughwritableByteCount()
to write the amount of data given as an argument.DataBuffer
DataBufferWrapper. ensureCapacity(int capacity)
DataBuffer
DefaultDataBuffer. ensureCapacity(int length)
DataBuffer
NettyDataBuffer. ensureCapacity(int capacity)
DataBuffer
DataBufferFactory. join(List<? extends DataBuffer> dataBuffers)
Return a newDataBuffer
composed of thedataBuffers
elements joined together.DataBuffer
NettyDataBufferFactory. join(List<? extends DataBuffer> dataBuffers)
Return a newDataBuffer
composed of thedataBuffers
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 mostlength
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
DataBuffer. readPosition(int readPosition)
Set the position from which this buffer will read.DataBuffer
DataBufferWrapper. readPosition(int readPosition)
DataBuffer
LimitedDataBufferList. remove(int index)
default DataBuffer
DataBuffer. retainedSlice(int index, int length)
Create a newDataBuffer
whose contents is a shared, retained subsequence of this data buffer's content.DataBuffer
DataBufferWrapper. retainedSlice(int index, int length)
DataBuffer
LimitedDataBufferList. set(int index, DataBuffer element)
DataBuffer
DataBuffer. slice(int index, int length)
Create a newDataBuffer
whose contents is a shared subsequence of this data buffer's content.DataBuffer
DataBufferWrapper. slice(int index, int length)
DataBuffer
DataBufferFactory. wrap(byte[] bytes)
Wrap the givenbyte
array in aDataBuffer
.DataBuffer
DataBufferFactory. wrap(ByteBuffer byteBuffer)
Wrap the givenByteBuffer
in aDataBuffer
.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 mostlength
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 givenCharSequence
using the givenCharset
, starting at the current writing position.DataBuffer
DataBuffer. write(ByteBuffer... buffers)
Write one or moreByteBuffer
to this buffer, starting at the current writing position.DataBuffer
DataBuffer. write(DataBuffer... buffers)
Write one or moreDataBuffer
s 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
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)
Methods in org.springframework.core.io.buffer that return types with arguments of type DataBuffer Modifier and Type Method Description static reactor.core.publisher.Mono<DataBuffer>
DataBufferUtils. join(org.reactivestreams.Publisher<? extends DataBuffer> dataBuffers)
Return a newDataBuffer
composed from joining together the givendataBuffers
elements.static reactor.core.publisher.Mono<DataBuffer>
DataBufferUtils. join(org.reactivestreams.Publisher<? extends DataBuffer> buffers, int maxByteCount)
Variant ofDataBufferUtils.join(Publisher)
that behaves the same way up until the specified max number of bytes to buffer.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)
static Consumer<DataBuffer>
DataBufferUtils. releaseConsumer()
Return a consumer that callsDataBufferUtils.release(DataBuffer)
on all passed data buffers.static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils. skipUntilByteCount(org.reactivestreams.Publisher<? extends DataBuffer> publisher, long maxByteCount)
Skip buffers from the givenPublisher
until the total byte count reaches the given maximum byte count, or until the publisher is complete.static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils. takeUntilByteCount(org.reactivestreams.Publisher<? extends DataBuffer> publisher, long maxByteCount)
Relay buffers from the givenPublisher
until the total byte count reaches the given maximum byte count, or until the publisher is complete.static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils. write(org.reactivestreams.Publisher<? extends DataBuffer> source, AsynchronousFileChannel channel, long position)
Write the given stream ofDataBuffers
to the givenAsynchronousFileChannel
.static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils. write(org.reactivestreams.Publisher<DataBuffer> source, OutputStream outputStream)
Write the given stream ofDataBuffers
to the givenOutputStream
.static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils. write(org.reactivestreams.Publisher<DataBuffer> source, AsynchronousFileChannel channel)
Write the given stream ofDataBuffers
to the givenAsynchronousFileChannel
.static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils. write(org.reactivestreams.Publisher<DataBuffer> source, WritableByteChannel channel)
Write the given stream ofDataBuffers
to the givenWritableByteChannel
.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(DataBuffer dataBuffer)
Release the given data buffer, if it is aPooledDataBuffer
and has been allocated.DataBuffer
LimitedDataBufferList. set(int index, DataBuffer element)
static io.netty.buffer.ByteBuf
NettyDataBufferFactory. toByteBuf(DataBuffer buffer)
Return the given NettyDataBuffer
as aByteBuf
.DataBuffer
DataBuffer. write(DataBuffer... buffers)
Write one or moreDataBuffer
s to this buffer, starting at the current writing position.DataBuffer
DataBufferWrapper. write(DataBuffer... buffers)
DefaultDataBuffer
DefaultDataBuffer. write(DataBuffer... buffers)
NettyDataBuffer
NettyDataBuffer. write(DataBuffer... buffers)
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 newDataBuffer
composed of thedataBuffers
elements joined together.static reactor.core.publisher.Mono<DataBuffer>
DataBufferUtils. join(org.reactivestreams.Publisher<? extends DataBuffer> dataBuffers)
Return a newDataBuffer
composed from joining together the givendataBuffers
elements.static reactor.core.publisher.Mono<DataBuffer>
DataBufferUtils. join(org.reactivestreams.Publisher<? extends DataBuffer> buffers, int maxByteCount)
Variant ofDataBufferUtils.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 newDataBuffer
composed of thedataBuffers
elements joined together.DataBuffer
NettyDataBufferFactory. join(List<? extends DataBuffer> dataBuffers)
Return a newDataBuffer
composed of thedataBuffers
elements joined together.boolean
LimitedDataBufferList. removeIf(Predicate<? super DataBuffer> filter)
static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils. skipUntilByteCount(org.reactivestreams.Publisher<? extends DataBuffer> publisher, long maxByteCount)
Skip buffers from the givenPublisher
until the total byte count reaches the given maximum byte count, or until the publisher is complete.static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils. takeUntilByteCount(org.reactivestreams.Publisher<? extends DataBuffer> publisher, long maxByteCount)
Relay buffers from the givenPublisher
until the total byte count reaches the given maximum byte count, or until the publisher is complete.static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils. write(org.reactivestreams.Publisher<? extends DataBuffer> source, AsynchronousFileChannel channel, long position)
Write the given stream ofDataBuffers
to the givenAsynchronousFileChannel
.static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils. write(org.reactivestreams.Publisher<DataBuffer> source, OutputStream outputStream)
Write the given stream ofDataBuffers
to the givenOutputStream
.static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils. write(org.reactivestreams.Publisher<DataBuffer> source, AsynchronousFileChannel channel)
Write the given stream ofDataBuffers
to the givenAsynchronousFileChannel
.static reactor.core.publisher.Flux<DataBuffer>
DataBufferUtils. write(org.reactivestreams.Publisher<DataBuffer> source, WritableByteChannel channel)
Write the given stream ofDataBuffers
to the givenWritableByteChannel
.static reactor.core.publisher.Mono<Void>
DataBufferUtils. write(org.reactivestreams.Publisher<DataBuffer> source, Path destination, OpenOption... options)
Write the given stream ofDataBuffers
to the given filePath
.Constructors in org.springframework.core.io.buffer with parameters of type DataBuffer Constructor Description DataBufferWrapper(DataBuffer delegate)
Create a newDataBufferWrapper
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 reactor.core.publisher.Flux<DataBuffer>
ReactiveHttpInputMessage. getBody()
Return the body of the message as aPublisher
.Method parameters in org.springframework.http with type arguments of type DataBuffer Modifier and Type Method Description reactor.core.publisher.Mono<Void>
ReactiveHttpOutputMessage. writeAndFlushWith(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> body)
Use the givenPublisher
ofPublishers
to write the body of the HttpOutputMessage to the underlying HTTP layer, flushing after eachPublisher<DataBuffer>
.reactor.core.publisher.Mono<Void>
ReactiveHttpOutputMessage. writeWith(org.reactivestreams.Publisher<? extends DataBuffer> body)
Use the givenPublisher
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 reactor.core.publisher.Flux<DataBuffer>
ClientHttpResponseDecorator. getBody()
Method parameters in org.springframework.http.client.reactive with type arguments of type DataBuffer Modifier and Type Method Description reactor.core.publisher.Mono<Void>
ClientHttpRequestDecorator. writeAndFlushWith(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> body)
reactor.core.publisher.Mono<Void>
ClientHttpRequestDecorator. writeWith(org.reactivestreams.Publisher<? extends DataBuffer> body)
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 reactor.core.publisher.Flux<DataBuffer>
Jackson2CborEncoder. encode(org.reactivestreams.Publisher<?> inputStream, DataBufferFactory bufferFactory, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
Method parameters in org.springframework.http.codec.cbor with type arguments of type DataBuffer Modifier and Type Method Description reactor.core.publisher.Flux<Object>
Jackson2CborDecoder. decode(org.reactivestreams.Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, 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, MimeType mimeType, Map<String,Object> hints)
Methods in org.springframework.http.codec.json that return types with arguments of type DataBuffer 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)
protected reactor.core.publisher.Flux<DataBuffer>
AbstractJackson2Decoder. processInput(org.reactivestreams.Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
Process the input publisher into a flux.protected reactor.core.publisher.Flux<DataBuffer>
Jackson2JsonDecoder. processInput(org.reactivestreams.Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, 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, MimeType mimeType, Map<String,Object> hints)
Method parameters in org.springframework.http.codec.json with type arguments of type DataBuffer Modifier and Type Method Description reactor.core.publisher.Flux<Object>
AbstractJackson2Decoder. decode(org.reactivestreams.Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
reactor.core.publisher.Mono<Object>
AbstractJackson2Decoder. decodeToMono(org.reactivestreams.Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
protected reactor.core.publisher.Flux<DataBuffer>
AbstractJackson2Decoder. processInput(org.reactivestreams.Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
Process the input publisher into a flux.protected reactor.core.publisher.Flux<DataBuffer>
Jackson2JsonDecoder. processInput(org.reactivestreams.Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
Uses of DataBuffer in org.springframework.http.codec.multipart
Methods in org.springframework.http.codec.multipart that return types with arguments of type DataBuffer Modifier and Type Method Description reactor.core.publisher.Flux<DataBuffer>
Part. content()
Return the content for this part.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, MimeType mimeType, Map<String,Object> hints)
Methods in org.springframework.http.codec.protobuf that return types with arguments of type DataBuffer 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)
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, MimeType mimeType, Map<String,Object> hints)
Method parameters in org.springframework.http.codec.protobuf with type arguments of type DataBuffer Modifier and Type Method Description reactor.core.publisher.Flux<com.google.protobuf.Message>
ProtobufDecoder. decode(org.reactivestreams.Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
reactor.core.publisher.Mono<com.google.protobuf.Message>
ProtobufDecoder. decodeToMono(org.reactivestreams.Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, 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, MimeType mimeType, Map<String,Object> hints)
Methods in org.springframework.http.codec.xml that return types with arguments of type DataBuffer 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)
Methods in org.springframework.http.codec.xml with parameters of type DataBuffer Modifier and Type Method Description Object
Jaxb2XmlDecoder. decode(DataBuffer dataBuffer, ResolvableType targetType, MimeType mimeType, Map<String,Object> hints)
Method parameters in org.springframework.http.codec.xml with type arguments of type DataBuffer Modifier and Type Method Description reactor.core.publisher.Flux<Object>
Jaxb2XmlDecoder. decode(org.reactivestreams.Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
reactor.core.publisher.Flux<XMLEvent>
XmlEventDecoder. decode(org.reactivestreams.Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)
reactor.core.publisher.Mono<Object>
Jaxb2XmlDecoder. decodeToMono(org.reactivestreams.Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, 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 org.reactivestreams.Processor<? super org.reactivestreams.Publisher<? extends DataBuffer>,Void>
AbstractListenerServerHttpResponse. createBodyFlushProcessor()
Abstract template method to create aProcessor<Publisher<DataBuffer>, Void>
that will write the response body with flushes to the underlying output.reactor.core.publisher.Flux<DataBuffer>
ServerHttpRequestDecorator. getBody()
Method parameters in org.springframework.http.server.reactive with type arguments of type DataBuffer Modifier and Type Method Description reactor.core.publisher.Mono<Void>
AbstractServerHttpResponse. writeAndFlushWith(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> body)
reactor.core.publisher.Mono<Void>
HttpHeadResponseDecorator. writeAndFlushWith(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> body)
InvokeServerHttpResponseDecorator.setComplete()
without writing.reactor.core.publisher.Mono<Void>
ServerHttpResponseDecorator. writeAndFlushWith(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> body)
protected reactor.core.publisher.Mono<Void>
AbstractListenerServerHttpResponse. writeAndFlushWithInternal(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> body)
protected abstract reactor.core.publisher.Mono<Void>
AbstractServerHttpResponse. writeAndFlushWithInternal(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> body)
Write to the underlying the response, and flush after eachPublisher<DataBuffer>
.reactor.core.publisher.Mono<Void>
AbstractServerHttpResponse. writeWith(org.reactivestreams.Publisher<? extends DataBuffer> body)
reactor.core.publisher.Mono<Void>
HttpHeadResponseDecorator. writeWith(org.reactivestreams.Publisher<? extends DataBuffer> body)
Consume and release the body without writing.reactor.core.publisher.Mono<Void>
ServerHttpResponseDecorator. writeWith(org.reactivestreams.Publisher<? extends DataBuffer> body)
protected reactor.core.publisher.Mono<Void>
AbstractListenerServerHttpResponse. writeWithInternal(org.reactivestreams.Publisher<? extends DataBuffer> body)
protected abstract reactor.core.publisher.Mono<Void>
AbstractServerHttpResponse. writeWithInternal(org.reactivestreams.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 reactor.core.publisher.Mono<Void>
AbstractEncoderMethodReturnValueHandler. handleEncodedContent(reactor.core.publisher.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 thePayload
, and also to release thePayload
.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 reactor.core.publisher.Mono<Void>
RSocketPayloadReturnValueHandler. handleEncodedContent(reactor.core.publisher.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 reactor.core.publisher.Flux<DataBuffer>
MockClientHttpRequest. getBody()
Return the request body, or an error stream if the body was never set or whenMockClientHttpRequest.setWriteHandler(java.util.function.Function<reactor.core.publisher.Flux<org.springframework.core.io.buffer.DataBuffer>, reactor.core.publisher.Mono<java.lang.Void>>)
is configured.reactor.core.publisher.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(org.reactivestreams.Publisher<DataBuffer> body)
void
MockClientHttpRequest. setWriteHandler(Function<reactor.core.publisher.Flux<DataBuffer>,reactor.core.publisher.Mono<Void>> writeHandler)
Configure a custom handler for writing the request body.reactor.core.publisher.Mono<Void>
MockClientHttpRequest. writeAndFlushWith(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> body)
reactor.core.publisher.Mono<Void>
MockClientHttpRequest. writeWith(org.reactivestreams.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 reactor.core.publisher.Flux<DataBuffer>
MockServerHttpRequest. getBody()
reactor.core.publisher.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(org.reactivestreams.Publisher<? extends DataBuffer> body)
Set the body of the request and build it.void
MockServerHttpResponse. setWriteHandler(Function<reactor.core.publisher.Flux<DataBuffer>,reactor.core.publisher.Mono<Void>> writeHandler)
Configure a custom handler to consume the response body.protected reactor.core.publisher.Mono<Void>
MockServerHttpResponse. writeAndFlushWithInternal(org.reactivestreams.Publisher<? extends org.reactivestreams.Publisher<? extends DataBuffer>> body)
protected reactor.core.publisher.Mono<Void>
MockServerHttpResponse. writeWithInternal(org.reactivestreams.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 org.reactivestreams.Publisher<DataBuffer>>
BodyInserter<T,ReactiveHttpOutputMessage>BodyInserters. fromDataBuffers(T publisher)
Inserter to write the givenPublisher<DataBuffer>
to the body.Methods in org.springframework.web.reactive.function that return types with arguments of type DataBuffer Modifier and Type Method Description static BodyExtractor<reactor.core.publisher.Flux<DataBuffer>,ReactiveHttpInputMessage>
BodyExtractors. toDataBuffers()
Extractor that returns the rawDataBuffers
.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(reactor.core.publisher.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(reactor.core.publisher.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 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.Constructors in org.springframework.web.reactive.socket with parameters of type DataBuffer Constructor Description WebSocketMessage(WebSocketMessage.Type type, DataBuffer payload)
Constructor for a WebSocketMessage.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)