Skip to content

Commit 12991df

Browse files
author
zhangxin
committed
修复close阻塞
1 parent b5dd3dc commit 12991df

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

java/src/main/java/com/baidubce/appbuilder/base/utils/iterator/StreamIterator.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -15,14 +15,14 @@ public class StreamIterator<T> implements Iterator<T>, AutoCloseable {
1515
private final CloseableHttpResponse resp;
1616
private final BufferedReader reader;
1717
private final Type bodyType;
18-
private final HttpUriRequestBase cancellable;
18+
private final HttpUriRequestBase request;
1919
private String nextLine;
2020

21-
public StreamIterator(CloseableHttpResponse resp, Type type, HttpUriRequestBase cancellable) throws IOException {
21+
public StreamIterator(CloseableHttpResponse resp, Type type, HttpUriRequestBase request) throws IOException {
2222
this.resp = resp;
2323
this.reader = new BufferedReader(new InputStreamReader(resp.getEntity().getContent()));
2424
this.bodyType = type;
25-
this.cancellable = cancellable;
25+
this.request = request;
2626
}
2727

2828
@Override
@@ -60,8 +60,8 @@ public T next() {
6060

6161
@Override
6262
public void close() {
63-
if (cancellable != null) {
64-
cancellable.abort();
63+
if (request != null) {
64+
request.abort();
6565
}
6666
try {
6767
if (reader != null) {

0 commit comments

Comments
 (0)