com.basho.riak.client.raw.pbc

Class PBStreamingOperation<S,T>

java.lang.Object

com.basho.riak.client.raw.pbc.PBStreamingOperation<S,T>

All Implemented Interfaces:

StreamingOperation<T>, Iterable<T>, Iterator<T>

Direct Known Subclasses:

PBStreamingIndex, PBStreamingList

public abstract class PBStreamingOperation<S,T>
extends Object
implements StreamingOperation<T>

Author:

Brian Roach

Field Summary

Fields

Modifier and Type	Field and Description
protected RiakStreamClient<S>	client

Constructor Summary

Constructors

Constructor and Description
PBStreamingOperation(RiakStreamClient<S> client)

Method Summary

Methods

Modifier and Type	Method and Description
void	cancel() Cancels the operation and cleans up the underlying network connection
List<T>	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<T>	iterator()
abstract T	next()
void	remove()

Methods inherited from class java.lang.Object

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

Field Detail

client

protected final RiakStreamClient<S> client

Constructor Detail

PBStreamingOperation

public PBStreamingOperation(RiakStreamClient<S> client)

Method Detail

getAll

public List<T> getAll()

Description copied from interface: StreamingOperation

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

Specified by:

getAll in interface StreamingOperation<T>

Returns:

a List containing all elements resulting from the operation

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<T>

iterator

public Iterator<T> iterator()

Specified by:

iterator in interface Iterable<T>

next

public abstract T next()

Specified by:

next in interface Iterator<T>

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<T>

remove

public void remove()

Specified by:

remove in interface Iterator<T>

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<T>

getContinuation

public String getContinuation()

Description copied from interface: StreamingOperation

Get the continuation value

Specified by:

getContinuation in interface StreamingOperation<T>

Returns:

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