Skip to content

Commit b357b13

Browse files
JacksonSerdeFactory now uses ByteBufferBackedInputStream for deserialization
1 parent d3b53bf commit b357b13

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

sdk-serde-jackson/src/main/java/dev/restate/serde/jackson/JacksonSerdeFactory.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
import com.fasterxml.jackson.core.JsonProcessingException;
1414
import com.fasterxml.jackson.databind.JavaType;
1515
import com.fasterxml.jackson.databind.ObjectMapper;
16+
import com.fasterxml.jackson.databind.util.ByteBufferBackedInputStream;
1617
import com.github.victools.jsonschema.generator.SchemaGenerator;
1718
import dev.restate.common.Slice;
1819
import dev.restate.serde.Serde;
@@ -84,7 +85,8 @@ public Slice serialize(T value) {
8485
@Override
8586
public T deserialize(@NonNull Slice value) {
8687
try {
87-
return mapper.readValue(value.toByteArray(), constructedType);
88+
return mapper.readValue(
89+
new ByteBufferBackedInputStream(value.asReadOnlyByteBuffer()), constructedType);
8890
} catch (IOException e) {
8991
sneakyThrow(e);
9092
return null;

0 commit comments

Comments
 (0)