com.basho.riak.pbc

Class IndexSource

java.lang.Object

com.basho.riak.pbc.RiakStreamClient<IndexEntry>

com.basho.riak.pbc.IndexSource

All Implemented Interfaces:

Iterable<IndexEntry>

public class IndexSource
extends RiakStreamClient<IndexEntry>

Author:

Brian Roach

Field Summary

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

conn, continuation

Constructor Summary

Constructors

Constructor and Description
IndexSource(RiakClient client, com.basho.riak.pbc.RiakConnection conn, IndexRequest request)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	hasNext()
IndexEntry	next()

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

cancel, 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

IndexSource

public IndexSource(RiakClient client,
           com.basho.riak.pbc.RiakConnection conn,
           IndexRequest request)
            throws IOException

Throws:

IOException

Method Detail

hasNext

public boolean hasNext()
                throws IOException

Specified by:

hasNext in class RiakStreamClient<IndexEntry>

Throws:

IOException

next

public IndexEntry next()
                throws IOException

Specified by:

next in class RiakStreamClient<IndexEntry>

Throws:

IOException