T
- public abstract class RiakStreamClient<T> extends Object implements Iterable<T>
Modifier and Type | Field and Description |
---|---|
protected com.basho.riak.pbc.RiakConnection |
conn |
protected com.google.protobuf.ByteString |
continuation |
Modifier | Constructor and Description |
---|---|
protected |
RiakStreamClient(RiakClient client,
com.basho.riak.pbc.RiakConnection conn) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
com.google.protobuf.ByteString |
getContinuation() |
boolean |
hasContinuation() |
abstract boolean |
hasNext() |
boolean |
isClosed() |
Iterator<T> |
iterator() |
abstract T |
next() |
protected com.basho.riak.pbc.RiakConnection conn
protected com.google.protobuf.ByteString continuation
protected RiakStreamClient(RiakClient client, com.basho.riak.pbc.RiakConnection conn)
public boolean hasContinuation()
public com.google.protobuf.ByteString getContinuation()
public void close()
public boolean isClosed()
public abstract boolean hasNext() throws IOException
IOException
public abstract T next() throws IOException
IOException
Copyright © 2013. All Rights Reserved.