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

Fields

Modifier and Type	Field and Description
protected com.basho.riak.pbc.RiakConnection	conn

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
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>