com.basho.riak.pbc
Class KeySource

java.lang.Object
  com.basho.riak.pbc.KeySource

All Implemented Interfaces:

Iterable<com.google.protobuf.ByteString>

public class KeySource
extends Object

Wraps a stream of keys as an iterator.

Field Summary

protected com.basho.riak.pbc.RiakConnection

conn

Constructor Summary

KeySource(RiakClient client, com.basho.riak.pbc.RiakConnection conn)

Method Summary

void	close()
boolean	hasNext()
boolean	isClosed()
Iterator<T>	iterator()
com.google.protobuf.ByteString	next()

Methods inherited from class java.lang.Object

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

Field Detail

conn

protected com.basho.riak.pbc.RiakConnection conn

Constructor Detail

KeySource

public KeySource(RiakClient client,
                 com.basho.riak.pbc.RiakConnection conn)
          throws IOException

Throws:

IOException

Method Detail

hasNext

public boolean hasNext()
                throws IOException

Throws:

IOException

next

public com.google.protobuf.ByteString next()
                                    throws IOException

Throws:

IOException

close

public void close()

isClosed

public boolean isClosed()

iterator

public Iterator<T> iterator()

Specified by:

iterator in interface Iterable<T>