public class ListKeysOperation extends PBFutureOperation<QueryResult,com.basho.riak.protobuf.RiakTsPB.TsListKeysResp,String>
Modifier and Type | Class and Description |
---|---|
static class |
ListKeysOperation.Builder |
reqBuilder
Modifier and Type | Method and Description |
---|---|
protected QueryResult |
convert(List<com.basho.riak.protobuf.RiakTsPB.TsListKeysResp> rawResponses) |
protected boolean |
done(com.basho.riak.protobuf.RiakTsPB.TsListKeysResp message)
Detect when the streaming operation is finished
|
String |
getQueryInfo()
Returns information related to the operation performed.
|
checkAndGetSingleResponse, createChannelMessage, decode
addListener, await, await, cancel, cause, channelMessage, get, get, getNow, isCancelled, isDone, isSuccess, removeListener, setResponse
protected QueryResult convert(List<com.basho.riak.protobuf.RiakTsPB.TsListKeysResp> rawResponses)
convert
in class FutureOperation<QueryResult,com.basho.riak.protobuf.RiakTsPB.TsListKeysResp,String>
public String getQueryInfo()
RiakFuture
Useful in async operations when you want to know what operation this future refers to.
getQueryInfo
in interface RiakFuture<QueryResult,String>
getQueryInfo
in class FutureOperation<QueryResult,com.basho.riak.protobuf.RiakTsPB.TsListKeysResp,String>
protected boolean done(com.basho.riak.protobuf.RiakTsPB.TsListKeysResp message)
FutureOperation
done
in class FutureOperation<QueryResult,com.basho.riak.protobuf.RiakTsPB.TsListKeysResp,String>
message
- raw messageCopyright © 2016. All rights reserved.