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