private class HttpClientTransportOverHTTP2.SessionListenerPromise extends Session.Listener.Adapter implements Promise<Session>
Promise.Adapter<U>, Promise.Completable<S>, Promise.Wrapper<W>
Session.Listener.Adapter
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.atomic.AtomicMarkableReference<HttpConnectionOverHTTP2> |
connection |
private java.util.Map<java.lang.String,java.lang.Object> |
context |
Modifier | Constructor and Description |
---|---|
private |
SessionListenerPromise(java.util.Map<java.lang.String,java.lang.Object> context) |
Modifier and Type | Method and Description |
---|---|
private Promise<Connection> |
connectionPromise() |
private HttpDestinationOverHTTP2 |
destination() |
private boolean |
failConnectionPromise(java.lang.Throwable failure) |
void |
failed(java.lang.Throwable failure)
Callback invoked when the operation fails.
|
void |
onClose(Session session,
GoAwayFrame frame) |
void |
onFailure(Session session,
java.lang.Throwable failure) |
boolean |
onIdleTimeout(Session session)
Callback method invoked when the idle timeout expired.
|
private void |
onServerPreface(Session session) |
void |
onSettings(Session session,
SettingsFrame frame)
Callback method invoked when a SETTINGS frame has been received.
|
void |
succeeded(Session session)
Callback invoked when the operation completes.
|
onNewStream, onPing, onPreface, onReset
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onClose, onFailure
private final java.util.concurrent.atomic.AtomicMarkableReference<HttpConnectionOverHTTP2> connection
private final java.util.Map<java.lang.String,java.lang.Object> context
private SessionListenerPromise(java.util.Map<java.lang.String,java.lang.Object> context)
public void succeeded(Session session)
Promise
Callback invoked when the operation completes.
succeeded
in interface Promise<Session>
session
- the contextPromise.failed(Throwable)
public void failed(java.lang.Throwable failure)
Promise
Callback invoked when the operation fails.
private HttpDestinationOverHTTP2 destination()
private Promise<Connection> connectionPromise()
public void onSettings(Session session, SettingsFrame frame)
Session.Listener
Callback method invoked when a SETTINGS frame has been received.
onSettings
in interface Session.Listener
onSettings
in class Session.Listener.Adapter
session
- the sessionframe
- the SETTINGS frame receivedprivate void onServerPreface(Session session)
public void onClose(Session session, GoAwayFrame frame)
onClose
in interface Session.Listener
onClose
in class Session.Listener.Adapter
public boolean onIdleTimeout(Session session)
Session.Listener
Callback method invoked when the idle timeout expired.
onIdleTimeout
in interface Session.Listener
onIdleTimeout
in class Session.Listener.Adapter
session
- the sessionpublic void onFailure(Session session, java.lang.Throwable failure)
onFailure
in interface Session.Listener
onFailure
in class Session.Listener.Adapter
private boolean failConnectionPromise(java.lang.Throwable failure)