com.basho.riak.client.core

Interface StreamingRiakFuture<ResultType,QueryInfoType>

Type Parameters:

ResultType - the streaming and non-streaming (response) return type

QueryInfoType - The query info type

All Superinterfaces:

Future<ResultType>, RiakFuture<ResultType,QueryInfoType>

All Known Implementing Classes:

ListBucketsOperation, ListKeysOperation, MapReduceOperation, PBStreamingFutureOperation, SecondaryIndexQueryOperation

public interface StreamingRiakFuture<ResultType,QueryInfoType>
extends RiakFuture<ResultType,QueryInfoType>

The result of an asynchronous streaming (chunked) Riak operation.

Since:

2.1.0

Author:

Alex Moore

Method Summary

Modifier and Type	Method and Description
TransferQueue<ResultType>	getResultsQueue() An Queue that provides the stream of results as they return from Riak.

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

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

Method Detail

getResultsQueue

TransferQueue<ResultType> getResultsQueue()

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

Returns:

An Queue.