private class JettyXhrTransport.SockJsResponseListener
extends Response.Listener.Adapter
Response
Listener
that splits the body of the response into SockJS frames and
delegates them to the XhrClientSockJsSession
.Modifier and Type | Field and Description |
---|---|
private SettableListenableFuture<WebSocketSession> |
connectFuture |
private java.io.ByteArrayOutputStream |
outputStream |
private HttpHeaders |
receiveHeaders |
private XhrClientSockJsSession |
sockJsSession |
private java.net.URI |
transportUrl |
Constructor and Description |
---|
SockJsResponseListener(java.net.URI url,
HttpHeaders headers,
XhrClientSockJsSession sockJsSession,
SettableListenableFuture<WebSocketSession> connectFuture) |
Modifier and Type | Method and Description |
---|---|
private void |
handleFrame() |
void |
onBegin(Response response) |
void |
onContent(Response response,
java.nio.ByteBuffer buffer) |
void |
onFailure(Response response,
java.lang.Throwable failure) |
void |
onHeaders(Response response) |
void |
onSuccess(Response response) |
private final java.net.URI transportUrl
private final HttpHeaders receiveHeaders
private final XhrClientSockJsSession sockJsSession
private final SettableListenableFuture<WebSocketSession> connectFuture
private final java.io.ByteArrayOutputStream outputStream
public SockJsResponseListener(java.net.URI url, HttpHeaders headers, XhrClientSockJsSession sockJsSession, SettableListenableFuture<WebSocketSession> connectFuture)
public void onBegin(Response response)
public void onHeaders(Response response)
public void onContent(Response response, java.nio.ByteBuffer buffer)
private void handleFrame()
public void onSuccess(Response response)
public void onFailure(Response response, java.lang.Throwable failure)