Skip to content

Commit

Permalink
Optimize moshi decoding (#2183)
Browse files Browse the repository at this point in the history
* perf: avoid writing full body to an intermediate string

* fix: eagerly return null for empty bodies

* chore(moshi): remove guava dependency

---------

Co-authored-by: Marvin Froeder <velo@users.noreply.github.com>
  • Loading branch information
iProdigy and velo authored Sep 30, 2023
1 parent 77acebc commit c14c838
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 23 deletions.
6 changes: 0 additions & 6 deletions moshi/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -42,12 +42,6 @@
<artifactId>moshi</artifactId>
</dependency>

<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>${guava.version}</version>
</dependency>

<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>feign-core</artifactId>
Expand Down
24 changes: 7 additions & 17 deletions moshi/src/main/java/feign/moshi/MoshiDecoder.java
Original file line number Diff line number Diff line change
Expand Up @@ -13,19 +13,16 @@
*/
package feign.moshi;

import com.google.common.io.CharStreams;
import com.squareup.moshi.JsonAdapter;
import com.squareup.moshi.JsonDataException;
import com.squareup.moshi.JsonEncodingException;
import com.squareup.moshi.Moshi;
import feign.Response;
import feign.Util;
import feign.codec.Decoder;
import okio.BufferedSource;
import okio.Okio;
import java.io.IOException;
import java.io.Reader;
import java.lang.reflect.Type;
import static feign.Util.UTF_8;
import static feign.Util.ensureClosed;

public class MoshiDecoder implements Decoder {
private final Moshi moshi;
Expand All @@ -42,7 +39,6 @@ public MoshiDecoder(Iterable<JsonAdapter<?>> adapters) {
this(MoshiFactory.create(adapters));
}


@Override
public Object decode(Response response, Type type) throws IOException {
JsonAdapter<Object> jsonAdapter = moshi.adapter(type);
Expand All @@ -52,23 +48,17 @@ public Object decode(Response response, Type type) throws IOException {
if (response.body() == null)
return null;

Reader reader = response.body().asReader(UTF_8);

try {
return parseJson(jsonAdapter, reader);
try (BufferedSource source = Okio.buffer(Okio.source(response.body().asInputStream()))) {
if (source.exhausted()) {
return null; // empty body
}
return jsonAdapter.fromJson(source);
} catch (JsonDataException e) {
if (e.getCause() != null && e.getCause() instanceof IOException) {
throw (IOException) e.getCause();
}
throw e;
} finally {
ensureClosed(reader);
}
}

private Object parseJson(JsonAdapter<Object> jsonAdapter, Reader reader) throws IOException {
String targetString = CharStreams.toString(reader);
return jsonAdapter.fromJson(targetString);
}
}

0 comments on commit c14c838

Please sign in to comment.