com.basho.riak.client.raw.http

Class BucketSource

java.lang.Object

com.basho.riak.client.raw.http.BucketSource

All Implemented Interfaces:

StreamingOperation<String>, Iterable<String>, Iterator<String>

public class BucketSource
extends Object
implements StreamingOperation<String>

Wraps the stream of keys from BucketResponse.getBucketInfo.getKeys in an iterator, handles closing the underlying http stream when finished.

Author:

russell, Brian Roach

Constructor Summary

Constructors

Constructor and Description
BucketSource(ListBucketsResponse listBucketsResponse) Create a Key Source from an http.ListBucketsResponse in response to {@link RiakClient#listBuckets(boolean) request.

Method Summary

Methods

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BucketSource

public BucketSource(ListBucketsResponse listBucketsResponse)

Create a Key Source from an http.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.

Parameters:

listBucketsResponse - the ListBucketsResponse with a List of buckets.

Method Detail

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<String>

next

public String next()

Specified by:

next in interface Iterator<String>

cancel

public void cancel()

Description copied from interface: StreamingOperation

Cancels the operation and cleans up the underlying network connection

Specified by:

cancel in interface StreamingOperation<String>

iterator

public Iterator<String> iterator()

Specified by:

iterator in interface Iterable<String>

remove

public void remove()

Specified by:

remove in interface Iterator<String>

getAll

public List<String> getAll()

Description copied from interface: StreamingOperation

Retrieve all elements from the operation and return them in a List

Specified by:

getAll in interface StreamingOperation<String>

Returns:

a List containing all elements resulting from the operation

hasContinuation

public boolean hasContinuation()

Description copied from interface: StreamingOperation

If this is a paginated operation, a "continuation" value may be available

Specified by:

hasContinuation in interface StreamingOperation<String>

getContinuation

public String getContinuation()

Description copied from interface: StreamingOperation

Get the continuation value

Specified by:

getContinuation in interface StreamingOperation<String>

Returns:

A string representation of the continuation value or null if not present