com.basho.riak.pbc

Class BucketSource

java.lang.Object

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

com.basho.riak.pbc.BucketSource

All Implemented Interfaces:

Iterable<com.google.protobuf.ByteString>

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

Author:

Brian Roach

Field Summary

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

conn, continuation

Constructor Summary

Constructors

Constructor and Description
BucketSource(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

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

BucketSource

public BucketSource(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