ra/runelite
1
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

http service: close response body

Browse Source
This commit is contained in:
Adam
2017-05-02 08:12:12 -04:00
parent 1ffb146474
commit b0135776f8
3 changed files with 20 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
http-api/src/main/java/net/runelite/http/api/hiscore/HiscoreClient.java
View File

@@ -34,6 +34,7 @@ import okhttp3.HttpUrl;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.ResponseBody;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -60,7 +61,10 @@ public class HiscoreClient
Response response = client.newCall(request).execute();
InputStream in = response.body().byteStream();
return gson.fromJson(new InputStreamReader(in), HiscoreResult.class);
try (ResponseBody body = response.body())
{
InputStream in = body.byteStream();
return gson.fromJson(new InputStreamReader(in), HiscoreResult.class);
}
}
}

9
http-service/src/main/java/net/runelite/http/service/hiscore/HiscoreService.java
View File

@@ -32,6 +32,7 @@ import okhttp3.HttpUrl;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.ResponseBody;
import org.apache.commons.csv.CSVFormat;
import org.apache.commons.csv.CSVParser;
import org.apache.commons.csv.CSVRecord;
@@ -53,8 +54,14 @@ public class HiscoreService
.build();
Response response = client.newCall(request).execute();
String responseStr;
try (ResponseBody body = response.body())
{
responseStr = body.string();
}
CSVParser parser = CSVParser.parse(response.body().string(), CSVFormat.DEFAULT);
CSVParser parser = CSVParser.parse(responseStr, CSVFormat.DEFAULT);
HiscoreResultBuilder hiscoreBuilder = new HiscoreResultBuilder();
hiscoreBuilder.setPlayer(username);

7
http-service/src/main/java/net/runelite/http/service/worlds/WorldsService.java
View File

@@ -35,6 +35,7 @@ import okhttp3.HttpUrl;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.ResponseBody;
public class WorldsService
{
@@ -50,8 +51,12 @@ public class WorldsService
.build();
Response response = client.newCall(request).execute();
byte[] b;
byte[] b = response.body().bytes();
try (ResponseBody body = response.body())
{
b = body.bytes();
}
List<World> worlds = new ArrayList<>();
ByteBuffer buf = ByteBuffer.wrap(b);