public class BucketSource extends Object implements StreamingOperation<String>
Constructor and Description |
---|
BucketSource(ListBucketsResponse listBucketsResponse)
Create a Key Source from an http.
ListBucketsResponse in response to
{@link RiakClient#listBuckets(boolean) request. |
Modifier and Type | Method and Description |
---|---|
void |
cancel()
Cancels the operation and cleans up the underlying network connection
|
List<String> |
getAll()
Retrieve all elements from the operation and return them in a List
|
String |
getContinuation()
Get the continuation value
|
boolean |
hasContinuation()
If this is a paginated operation, a "continuation" value may be available
|
boolean |
hasNext() |
Iterator<String> |
iterator() |
String |
next() |
void |
remove() |
public BucketSource(ListBucketsResponse listBucketsResponse)
ListBucketsResponse
in response to
{@link RiakClient#listBuckets(boolean) request. The bucket response
contains a stream which you must close if you do not iterate over the entire set.listBucketsResponse
- the ListBucketsResponse
with a List of buckets.public void cancel()
StreamingOperation
cancel
in interface StreamingOperation<String>
public List<String> getAll()
StreamingOperation
getAll
in interface StreamingOperation<String>
public boolean hasContinuation()
StreamingOperation
hasContinuation
in interface StreamingOperation<String>
public String getContinuation()
StreamingOperation
getContinuation
in interface StreamingOperation<String>
Copyright © 2013. All Rights Reserved.