public class ResponseProcessor<R extends AbstractResponse>
extends java.lang.Object
Constructor and Description |
---|
ResponseProcessor(SocketConnection<?,R> connection) |
Modifier and Type | Method and Description |
---|---|
void |
checkTimeout() |
<T extends R> |
registerHandler(java.lang.Class<? extends T> responseClass,
AbstractResponseHandler<T> handler) |
void |
registerHandler(int id,
AbstractResponseToRequestHandler<?> handler) |
void |
registerTimeoutHandler(int commandId,
int timeout,
java.lang.Runnable onTimeout) |
void |
startReading(ResponseReader<? extends R> reader) |
void |
stopReading() |
public ResponseProcessor(SocketConnection<?,R> connection)
public void startReading(ResponseReader<? extends R> reader)
public void stopReading()
public <T extends R> void registerHandler(java.lang.Class<? extends T> responseClass, AbstractResponseHandler<T> handler)
public void registerHandler(int id, AbstractResponseToRequestHandler<?> handler)
public void checkTimeout()
public void registerTimeoutHandler(int commandId, int timeout, java.lang.Runnable onTimeout)