Skip to content

Instantly share code, notes, and snippets.

@garethstokes
Created May 11, 2010 03:05
Show Gist options
  • Save garethstokes/396872 to your computer and use it in GitHub Desktop.
Save garethstokes/396872 to your computer and use it in GitHub Desktop.
public RiakResponse<string[]> ListKeysFor(ListKeysRequest request) {
var connection = _connectionManager.GetNextConnection();
var writeResponse = connection.WriteWith(requestObject: request,
method: RequestMethod.ListKeys);
return writeResponse.ResponseCode == RiakResponseCode.Failed
? RiakResponse<string[]>.WithErrors(writeResponse.Messages)
: RiakResponse<string[]>.ReadResponse(() => {
var readResponse = connection.Read<ListBucketsResponse>();
return readResponse.ResponseCode == RiakResponseCode.Failed
? RiakResponse<string[]>.WithErrors(readResponse.Messages)
: RiakResponse<string[]>.WithoutErrors(readResponse.Result
.Buckets
.Select(x => x.DecodeToString())
.ToArray());
});
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment