public interface RSocketStrategies
| Modifier and Type | Interface and Description |
|---|---|
static interface |
RSocketStrategies.Builder
The builder options for creating
RSocketStrategies. |
| Modifier and Type | Method and Description |
|---|---|
static RSocketStrategies.Builder |
builder()
Return a builder to build a new
RSocketStrategies instance. |
DataBufferFactory |
dataBufferFactory()
Return the configured
dataBufferFactory. |
default <T> Decoder<T> |
decoder(ResolvableType elementType,
MimeType mimeType)
Find a compatible Decoder for the given element type.
|
List<Decoder<?>> |
decoders()
Return the configured
decoders. |
default <T> Encoder<T> |
encoder(ResolvableType elementType,
MimeType mimeType)
Find a compatible Encoder for the given element type.
|
List<Encoder<?>> |
encoders()
Return the configured
encoders. |
default RSocketStrategies.Builder |
mutate()
Return a builder to create a new
RSocketStrategies instance
replicated from the current instance. |
ReactiveAdapterRegistry |
reactiveAdapterRegistry()
Return the configured
reactiveAdapterRegistry. |
List<Encoder<?>> encoders()
encoders.encoder(ResolvableType, MimeType)default <T> Encoder<T> encoder(ResolvableType elementType, @Nullable MimeType mimeType)
T - for casting the Encoder to the expected element typeelementType - the element type to matchmimeType - the MimeType to matchIllegalArgumentException - if no matching Encoder is foundList<Decoder<?>> decoders()
decoders.decoder(ResolvableType, MimeType)default <T> Decoder<T> decoder(ResolvableType elementType, @Nullable MimeType mimeType)
T - for casting the Decoder to the expected element typeelementType - the element type to matchmimeType - the MimeType to matchIllegalArgumentException - if no matching Decoder is foundReactiveAdapterRegistry reactiveAdapterRegistry()
reactiveAdapterRegistry.DataBufferFactory dataBufferFactory()
dataBufferFactory.static RSocketStrategies.Builder builder()
RSocketStrategies instance.default RSocketStrategies.Builder mutate()
RSocketStrategies instance
replicated from the current instance.