class GetMoreProtocol.GetMoreResultCallback extends ResponseCallback
Modifier and Type | Field and Description |
---|---|
private SingleResultCallback<QueryResult<T>> |
callback |
private CommandListener |
commandListener |
private ConnectionDescription |
connectionDescription |
private long |
cursorId |
private GetMoreMessage |
message |
private long |
startTimeNanos |
Constructor and Description |
---|
GetMoreResultCallback(SingleResultCallback<QueryResult<T>> callback,
long cursorId,
GetMoreMessage message,
ConnectionDescription connectionDescription,
CommandListener commandListener,
long startTimeNanos) |
Modifier and Type | Method and Description |
---|---|
protected void |
callCallback(ResponseBuffers responseBuffers,
java.lang.Throwable throwableFromCallback) |
getRequestId, getServerAddress, onResult
private final SingleResultCallback<QueryResult<T>> callback
private final long cursorId
private final GetMoreMessage message
private final ConnectionDescription connectionDescription
private final CommandListener commandListener
private final long startTimeNanos
public GetMoreResultCallback(SingleResultCallback<QueryResult<T>> callback, long cursorId, GetMoreMessage message, ConnectionDescription connectionDescription, CommandListener commandListener, long startTimeNanos)
protected void callCallback(ResponseBuffers responseBuffers, java.lang.Throwable throwableFromCallback)
callCallback
in class ResponseCallback