public final class Polling extends Transport implements javax.servlet.AsyncListener
Emitter.Listener
Modifier and Type | Field and Description |
---|---|
static String |
NAME |
mParser, mReadyState
Constructor and Description |
---|
Polling(Object lockObject,
Parser parser) |
Modifier and Type | Method and Description |
---|---|
protected void |
doClose()
Transport specific logic for closing transport.
|
Map<String,List<String>> |
getInitialHeaders()
Get the headers of the initial HTTP request.
|
Map<String,String> |
getInitialQuery()
Get the query parameters of the initial HTTP request.
|
String |
getName()
Get the name of this transport.
|
boolean |
isWritable()
Checks whether the transport is currently writable.
|
protected void |
onClose()
Called by child to indicate closure of transport.
|
void |
onComplete(javax.servlet.AsyncEvent asyncEvent) |
protected void |
onData(Object data)
Called by child to indicate data received from remote client.
|
void |
onError(javax.servlet.AsyncEvent asyncEvent) |
void |
onRequest(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response)
Handle a client HTTP request.
|
void |
onStartAsync(javax.servlet.AsyncEvent asyncEvent) |
void |
onTimeout(javax.servlet.AsyncEvent asyncEvent) |
void |
send(List<Packet<?>> packets)
Send a list of packets over the transport.
|
public static final String NAME
public Map<String,String> getInitialQuery()
Transport
getInitialQuery
in class Transport
public Map<String,List<String>> getInitialHeaders()
Transport
getInitialHeaders
in class Transport
public void onRequest(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response) throws IOException
Transport
onRequest
in class Transport
request
- The HTTP request object.response
- The HTTP response object.IOException
- On IO error.public void send(List<Packet<?>> packets)
Transport
public boolean isWritable()
Transport
isWritable
in class Transport
public String getName()
Transport
protected void doClose()
Transport
protected void onData(Object data)
Transport
protected void onClose()
Transport
public void onStartAsync(javax.servlet.AsyncEvent asyncEvent)
onStartAsync
in interface javax.servlet.AsyncListener
public void onComplete(javax.servlet.AsyncEvent asyncEvent)
onComplete
in interface javax.servlet.AsyncListener
public void onTimeout(javax.servlet.AsyncEvent asyncEvent)
onTimeout
in interface javax.servlet.AsyncListener
public void onError(javax.servlet.AsyncEvent asyncEvent)
onError
in interface javax.servlet.AsyncListener
Copyright © 2022. All rights reserved.