Skip to content

Commit 6a2a800

Browse files
authored
Update GitHubConnectorResponse.java
1 parent 445d8a5 commit 6a2a800

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

src/main/java/org/kohsuke/github/connector/GitHubConnectorResponse.java

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -161,7 +161,6 @@ public abstract static class ByteArrayResponse extends GitHubConnectorResponse {
161161
private boolean inputStreamRead = false;
162162
private byte[] inputBytes = null;
163163
private boolean isClosed = false;
164-
private boolean avoidBufferedResponseStream;
165164

166165
/**
167166
* Constructor for ByteArray Response
@@ -177,7 +176,6 @@ protected ByteArrayResponse(@Nonnull GitHubConnectorRequest request,
177176
int statusCode,
178177
@Nonnull Map<String, List<String>> headers) {
179178
super(request, statusCode, headers);
180-
avoidBufferedResponseStream = request.avoidBufferedResponseStream();
181179
}
182180

183181
/**
@@ -194,21 +192,21 @@ public InputStream bodyStream() throws IOException {
194192
InputStream body;
195193
if (!inputStreamRead) {
196194
body = wrapStream(rawBodyStream());
197-
if (!avoidBufferedResponseStream) {
195+
if (!request.avoidBufferedResponseStream()) {
198196
try (InputStream stream = body) {
199197
if (stream != null) {
200198
inputBytes = IOUtils.toByteArray(stream);
201199
}
202200
}
203201
}
204202
inputStreamRead = true;
205-
if (avoidBufferedResponseStream) {
203+
if (request.avoidBufferedResponseStream()) {
206204
return body;
207205
}
208206
}
209207
}
210208

211-
if (avoidBufferedResponseStream) {
209+
if (request.avoidBufferedResponseStream()) {
212210
throw new IOException("Response is already consumed");
213211
} else if (inputBytes == null) {
214212
throw new IOException("Response body missing, stream null");

0 commit comments

Comments
 (0)