com.basho.riak.pbc

Class RiakStreamClient<T>

java.lang.Object

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

Type Parameters:

T -

All Implemented Interfaces:

Iterable<T>

Direct Known Subclasses:

BucketSource, IndexSource, KeySource, MapReduceResponseSource

public abstract class RiakStreamClient<T>
extends Object
implements Iterable<T>

A general purpose stream -> iterator adaptor.

Field Summary

Fields

Modifier and Type	Field and Description
protected com.basho.riak.pbc.RiakConnection	conn
protected com.google.protobuf.ByteString	continuation

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RiakStreamClient(RiakClient client, com.basho.riak.pbc.RiakConnection conn)

Method Summary

Methods

Modifier and Type	Method and Description
void	cancel()
void	close()
com.google.protobuf.ByteString	getContinuation()
boolean	hasContinuation()
abstract boolean	hasNext()
boolean	isClosed()
Iterator<T>	iterator()
abstract T	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

continuation

protected com.google.protobuf.ByteString continuation

Constructor Detail

RiakStreamClient

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

Method Detail

hasContinuation

public boolean hasContinuation()

getContinuation

public com.google.protobuf.ByteString getContinuation()

cancel

public void cancel()

close

public void close()

isClosed

public boolean isClosed()

hasNext

public abstract boolean hasNext()
                         throws IOException

Throws:

IOException

next

public abstract T next()
                throws IOException

Throws:

IOException

iterator

public Iterator<T> iterator()

Specified by:

iterator in interface Iterable<T>