java.lang.Object
- org.springframework.core.codec.AbstractDecoder<T>
- - org.springframework.core.codec.AbstractDataBufferDecoder<T>

Type Parameters:
T - the element type
All Implemented Interfaces:
Decoder<T>
Direct Known Subclasses:
ByteArrayDecoder, ByteBufferDecoder, DataBufferDecoder, ResourceDecoder, StringDecoder
```
public abstract class AbstractDataBufferDecoder<T>
extends AbstractDecoder<T>
```
Abstract base class for Decoder implementations that can decode a DataBuffer directly to the target element type.
Sub-classes must implement decodeDataBuffer(org.springframework.core.io.buffer.DataBuffer, org.springframework.core.ResolvableType, org.springframework.util.MimeType, java.util.Map<java.lang.String, java.lang.Object>) to provide a way to transform a DataBuffer to the target data type. The default decode(org.reactivestreams.Publisher<org.springframework.core.io.buffer.DataBuffer>, org.springframework.core.ResolvableType, org.springframework.util.MimeType, java.util.Map<java.lang.String, java.lang.Object>) implementation transforms each individual data buffer while decodeToMono(org.reactivestreams.Publisher<org.springframework.core.io.buffer.DataBuffer>, org.springframework.core.ResolvableType, org.springframework.util.MimeType, java.util.Map<java.lang.String, java.lang.Object>) applies "reduce" and transforms the aggregated buffer.
Sub-classes can override decode(org.reactivestreams.Publisher<org.springframework.core.io.buffer.DataBuffer>, org.springframework.core.ResolvableType, org.springframework.util.MimeType, java.util.Map<java.lang.String, java.lang.Object>) in order to split the input stream along different boundaries (e.g. on new line characters for String) or always reduce to a single data buffer (e.g. Resource).
Since:
5.0
Author:
Rossen Stoyanchev

Field Summary
- Fields inherited from class org.springframework.core.codec.AbstractDecoder
  logger

Constructor Summary
Constructors
Modifier Constructor Description
protected AbstractDataBufferDecoder(MimeType... supportedMimeTypes)

Method Summary

All Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method	Description
`reactor.core.publisher.Flux<T>`	`decode(org.reactivestreams.Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)`	Decode a `DataBuffer` input stream into a Flux of `T`.
`protected T`	`decodeDataBuffer(DataBuffer buffer, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)`	Deprecated. as of 5.2, please implement `Decoder.decode(DataBuffer, ResolvableType, MimeType, Map)` instead
`reactor.core.publisher.Mono<T>`	`decodeToMono(org.reactivestreams.Publisher<DataBuffer> input, ResolvableType elementType, MimeType mimeType, Map<String,Object> hints)`	Decode a `DataBuffer` input stream into a Mono of `T`.
`int`	`getMaxInMemorySize()`	Return the `configured` byte count limit.
`void`	`setMaxInMemorySize(int byteCount)`	Configure a limit on the number of bytes that can be buffered whenever the input stream needs to be aggregated.

Methods inherited from class org.springframework.core.codec.AbstractDecoder
canDecode, getDecodableMimeTypes, getLogger, setLogger

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.core.codec.Decoder
decode

Constructor Detail

AbstractDataBufferDecoder

protected AbstractDataBufferDecoder(MimeType... supportedMimeTypes)

Method Detail

setMaxInMemorySize
```
public void setMaxInMemorySize(int byteCount)
```
Configure a limit on the number of bytes that can be buffered whenever the input stream needs to be aggregated. This can be a result of decoding to a single DataBuffer, ByteBuffer, byte[], Resource, String, etc. It can also occur when splitting the input stream, e.g. delimited text, in which case the limit applies to data buffered between delimiters.
By default this is set to 256K.
Parameters:
byteCount - the max number of bytes to buffer, or -1 for unlimited
Since:
5.1.11

getMaxInMemorySize
```
public int getMaxInMemorySize()
```
Return the configured byte count limit.
Since:
5.1.11

decode

public reactor.core.publisher.Flux<T> decode(org.reactivestreams.Publisher<DataBuffer> input,
                                             ResolvableType elementType,
                                             @Nullable
                                             MimeType mimeType,
                                             @Nullable
                                             Map<String,Object> hints)

Description copied from interface: Decoder

Decode a DataBuffer input stream into a Flux of T.

Parameters:: input - the DataBuffer input stream to decode; elementType - the expected type of elements in the output stream; this type must have been previously passed to the Decoder.canDecode(org.springframework.core.ResolvableType, org.springframework.util.MimeType) method and it must have returned true.; mimeType - the MIME type associated with the input stream (optional); hints - additional information about how to do encode
Returns:: the output stream with decoded elements

decodeToMono

public reactor.core.publisher.Mono<T> decodeToMono(org.reactivestreams.Publisher<DataBuffer> input,
                                                   ResolvableType elementType,
                                                   @Nullable
                                                   MimeType mimeType,
                                                   @Nullable
                                                   Map<String,Object> hints)

Description copied from interface: Decoder

Decode a DataBuffer input stream into a Mono of T.

Specified by:: decodeToMono in interface Decoder<T>
Overrides:: decodeToMono in class AbstractDecoder<T>
Parameters:: input - the DataBuffer input stream to decode; elementType - the expected type of elements in the output stream; this type must have been previously passed to the Decoder.canDecode(org.springframework.core.ResolvableType, org.springframework.util.MimeType) method and it must have returned true.; mimeType - the MIME type associated with the input stream (optional); hints - additional information about how to do encode
Returns:: the output stream with the decoded element

decodeDataBuffer

@Deprecated
@Nullable
protected T decodeDataBuffer(DataBuffer buffer,
                             ResolvableType elementType,
                             @Nullable
                             MimeType mimeType,
                             @Nullable
                             Map<String,Object> hints)

Deprecated.

as of 5.2, please implement Decoder.decode(DataBuffer, ResolvableType, MimeType, Map) instead

How to decode a DataBuffer to the target element type.

Class AbstractDataBufferDecoder<T>

Field Summary

Fields inherited from class org.springframework.core.codec.AbstractDecoder

Constructor Summary

Method Summary

Methods inherited from class org.springframework.core.codec.AbstractDecoder

Methods inherited from class java.lang.Object

Methods inherited from interface org.springframework.core.codec.Decoder