com.basho.riak.client.core

Class PBStreamingFutureOperation<ReturnType,ResponseType,QueryInfoType>

java.lang.Object

com.basho.riak.client.core.FutureOperation<T,U,S>

com.basho.riak.client.core.operations.PBFutureOperation<ReturnType,ResponseType,QueryInfoType>

com.basho.riak.client.core.PBStreamingFutureOperation<ReturnType,ResponseType,QueryInfoType>

Type Parameters:

ReturnType - The type returned by the streaming and non-streaming operation versions

ResponseType - The protocol type returned

QueryInfoType - Query info type

All Implemented Interfaces:

RiakFuture<ReturnType,QueryInfoType>, StreamingRiakFuture<ReturnType,QueryInfoType>, Future<ReturnType>

Direct Known Subclasses:

ListBucketsOperation, ListKeysOperation, MapReduceOperation, SecondaryIndexQueryOperation

public abstract class PBStreamingFutureOperation<ReturnType,ResponseType,QueryInfoType>
extends PBFutureOperation<ReturnType,ResponseType,QueryInfoType>
implements StreamingRiakFuture<ReturnType,QueryInfoType>

Since:

2.1.0

Author:

Alex Moore

Field Summary

Fields inherited from class com.basho.riak.client.core.operations.PBFutureOperation

reqBuilder, reqMessageCode

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PBStreamingFutureOperation(byte reqMessageCode, byte respMessageCode, com.google.protobuf.GeneratedMessage.Builder<?> reqBuilder, com.google.protobuf.Parser<ResponseType> respParser, boolean streamResults)

Method Summary

Modifier and Type	Method and Description
TransferQueue<ReturnType>	getResultsQueue() An Queue that provides the stream of results as they return from Riak.
protected void	processMessage(ResponseType decodedMessage)
protected abstract ReturnType	processStreamingChunk(ResponseType rawResponseChunk)

Methods inherited from class com.basho.riak.client.core.operations.PBFutureOperation

createChannelMessage, decode

Methods inherited from class com.basho.riak.client.core.FutureOperation

addListener, await, await, cancel, cause, channelMessage, checkAndGetSingleResponse, convert, done, get, get, getNow, getQueryInfo, isCancelled, isDone, isSuccess, processBatchMessage, removeListener, setComplete, setResponse

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.basho.riak.client.core.RiakFuture

addListener, await, await, cancel, cause, get, get, getNow, getQueryInfo, isCancelled, isDone, isSuccess, removeListener

Constructor Detail

PBStreamingFutureOperation

protected PBStreamingFutureOperation(byte reqMessageCode,
                                     byte respMessageCode,
                                     com.google.protobuf.GeneratedMessage.Builder<?> reqBuilder,
                                     com.google.protobuf.Parser<ResponseType> respParser,
                                     boolean streamResults)

Method Detail

processMessage

protected void processMessage(ResponseType decodedMessage)

Overrides:

processMessage in class FutureOperation<ReturnType,ResponseType,QueryInfoType>

processStreamingChunk

protected abstract ReturnType processStreamingChunk(ResponseType rawResponseChunk)

getResultsQueue

public final TransferQueue<ReturnType> getResultsQueue()

Description copied from interface: StreamingRiakFuture

An Queue that provides the stream of results as they return from Riak.

Specified by:

getResultsQueue in interface StreamingRiakFuture<ReturnType,QueryInfoType>

Returns:

An Queue.