parent
92b2c45281
commit
9990bd2ea8
|
|
@ -79,7 +79,7 @@ public class KotlinSerializationJsonDecoder extends AbstractDecoder<Object> {
|
|||
|
||||
@Override
|
||||
public Mono<Object> decodeToMono(Publisher<DataBuffer> inputStream, ResolvableType elementType, MimeType mimeType, Map<String, Object> hints) {
|
||||
return stringDecoder
|
||||
return this.stringDecoder
|
||||
.decodeToMono(inputStream, elementType, mimeType, hints)
|
||||
.map(jsonText -> this.json.decodeFromString(serializer(elementType.getType()), jsonText));
|
||||
}
|
||||
|
|
|
|||
|
|
@ -92,7 +92,7 @@ public class KotlinSerializationJsonEncoder extends AbstractEncoder<Object> {
|
|||
@Override
|
||||
public DataBuffer encodeValue(Object value, DataBufferFactory bufferFactory, ResolvableType valueType, MimeType mimeType, Map<String, Object> hints) {
|
||||
String json = this.json.encodeToString(serializer(valueType.getType()), value);
|
||||
return charSequenceEncoder.encodeValue(json, bufferFactory, valueType, mimeType, null);
|
||||
return this.charSequenceEncoder.encodeValue(json, bufferFactory, valueType, mimeType, null);
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
|
|||
Loading…
Reference in New Issue