private class UndertowXhrTransport.SockJsResponseListener
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private SettableListenableFuture<WebSocketSession> |
connectFuture |
private ClientConnection |
connection |
private HttpHeaders |
headers |
private java.io.ByteArrayOutputStream |
outputStream |
private TransportRequest |
request |
private XhrClientSockJsSession |
session |
private java.net.URI |
url |
Constructor and Description |
---|
SockJsResponseListener(TransportRequest request,
ClientConnection connection,
java.net.URI url,
HttpHeaders headers,
XhrClientSockJsSession sockJsSession,
SettableListenableFuture<WebSocketSession> connectFuture) |
Modifier and Type | Method and Description |
---|---|
void |
handleEvent(StreamSourceChannel channel) |
private void |
handleFrame() |
void |
onFailure(java.lang.Throwable failure) |
void |
onSuccess() |
void |
setup(StreamSourceChannel channel) |
private final TransportRequest request
private final ClientConnection connection
private final java.net.URI url
private final HttpHeaders headers
private final XhrClientSockJsSession session
private final SettableListenableFuture<WebSocketSession> connectFuture
private final java.io.ByteArrayOutputStream outputStream
public SockJsResponseListener(TransportRequest request, ClientConnection connection, java.net.URI url, HttpHeaders headers, XhrClientSockJsSession sockJsSession, SettableListenableFuture<WebSocketSession> connectFuture)