public abstract class PBStreamingOperation<S,T> extends Object implements StreamingOperation<T>
Modifier and Type | Field and Description |
---|---|
protected RiakStreamClient<S> |
client |
Constructor and Description |
---|
PBStreamingOperation(RiakStreamClient<S> client) |
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() |
protected final RiakStreamClient<S> client
public PBStreamingOperation(RiakStreamClient<S> client)
public List<T> getAll()
StreamingOperation
getAll
in interface StreamingOperation<T>
public void cancel()
StreamingOperation
cancel
in interface StreamingOperation<T>
public boolean hasContinuation()
StreamingOperation
hasContinuation
in interface StreamingOperation<T>
public String getContinuation()
StreamingOperation
getContinuation
in interface StreamingOperation<T>
Copyright © 2013. All Rights Reserved.