com.basho.riak.pbc

Class KeySource

java.lang.Object

com.basho.riak.pbc.RiakStreamClient<com.google.protobuf.ByteString>

com.basho.riak.pbc.KeySource

All Implemented Interfaces:

Iterable<com.google.protobuf.ByteString>

public class KeySource
extends RiakStreamClient<com.google.protobuf.ByteString>

Wraps a stream of keys as an iterator.

Field Summary

Fields inherited from class com.basho.riak.pbc.RiakStreamClient

conn, continuation

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
boolean	hasNext()
com.google.protobuf.ByteString	next()

Methods inherited from class com.basho.riak.pbc.RiakStreamClient

close, getContinuation, hasContinuation, isClosed, iterator

Methods inherited from class java.lang.Object

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

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

Specified by:

hasNext in class RiakStreamClient<com.google.protobuf.ByteString>

Throws:

IOException

next

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

Specified by:

next in class RiakStreamClient<com.google.protobuf.ByteString>

Throws:

IOException