Merged pull request #396.

This commit is contained in:
Simone Bordet 2016-03-07 10:46:22 +01:00
commit 6311c03dcc
1 changed files with 6 additions and 1 deletions

View File

@ -138,6 +138,11 @@ public class HttpClientTransportOverHTTP2 extends ContainerLifeCycle implements
return new HttpConnectionOverHTTP2(destination, session);
}
protected void onClose(HttpConnectionOverHTTP2 connection, GoAwayFrame frame)
{
connection.close();
}
private class SessionListenerPromise extends Session.Listener.Adapter implements Promise<Session>
{
private final HttpDestinationOverHTTP2 destination;
@ -182,7 +187,7 @@ public class HttpClientTransportOverHTTP2 extends ContainerLifeCycle implements
@Override
public void onClose(Session session, GoAwayFrame frame)
{
connection.close();
HttpClientTransportOverHTTP2.this.onClose(connection, frame);
}
@Override