auto close after async response
This commit is contained in:
parent
b97c7407d2
commit
b6930ac373
3 changed files with 4 additions and 3 deletions
|
@ -1,6 +1,6 @@
|
||||||
group = org.xbib
|
group = org.xbib
|
||||||
name = netty-http
|
name = netty-http
|
||||||
version = 4.1.63.2
|
version = 4.1.63.3
|
||||||
|
|
||||||
gradle.wrapper.version = 6.6.1
|
gradle.wrapper.version = 6.6.1
|
||||||
netty.version = 4.1.63.Final
|
netty.version = 4.1.63.Final
|
||||||
|
|
|
@ -73,7 +73,8 @@ public class RestClient {
|
||||||
requestBuilder.content(byteBuf);
|
requestBuilder.content(byteBuf);
|
||||||
}
|
}
|
||||||
client.newTransport(HttpAddress.http1(url))
|
client.newTransport(HttpAddress.http1(url))
|
||||||
.execute(requestBuilder.setResponseListener(restClient::setResponse).build()).close();
|
.execute(requestBuilder.setResponseListener(restClient::setResponse).build())
|
||||||
|
.close();
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
throw new IOException(e);
|
throw new IOException(e);
|
||||||
}
|
}
|
||||||
|
|
|
@ -94,6 +94,7 @@ public abstract class BaseTransport implements ClientTransport {
|
||||||
} else {
|
} else {
|
||||||
completableFuture.cancel(true);
|
completableFuture.cancel(true);
|
||||||
}
|
}
|
||||||
|
close();
|
||||||
});
|
});
|
||||||
execute(request);
|
execute(request);
|
||||||
return completableFuture;
|
return completableFuture;
|
||||||
|
@ -101,7 +102,6 @@ public abstract class BaseTransport implements ClientTransport {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void close() {
|
public void close() {
|
||||||
// channels are present, maybe forgot a get() to receive responses?
|
|
||||||
get();
|
get();
|
||||||
cancel();
|
cancel();
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue