Package com.streambase.sb.client

Class SimpleDequeueResult

java.lang.Object

com.streambase.sb.client.DequeueResult

com.streambase.sb.client.SimpleDequeueResult

All Implemented Interfaces:

Iterable<Tuple>

public class SimpleDequeueResult
extends DequeueResult

A simple concrete implementation of DequeueResult, primarily intended for use by implementors of DequeueResult.Interceptor to allow them to construct an alternative DequeueResult.

See Also:

DequeueResult

Nested Class Summary

Nested classes/interfaces inherited from class com.streambase.sb.client.DequeueResult

DequeueResult.Interceptor

Field Summary

Fields inherited from class com.streambase.sb.client.DequeueResult

CLOSED, GOOD, props, throwable, TIMEOUT

Constructor Summary

Constructors

Constructor	Description
SimpleDequeueResult(List<Tuple> tuples, StreamProperties props, StreamBaseURI server)	Constructor

Method Summary

Modifier and Type	Method	Description
int	getTupleCount()	Returns the number of tuples dequeued.
Iterator<Tuple>	iterator()	Returns an iterator of all tuples.

Methods inherited from class com.streambase.sb.client.DequeueResult

checkStatus, getSchema, getServerURI, getStatus, getStreamName, getStreamProperties, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

SimpleDequeueResult

public SimpleDequeueResult(List<Tuple> tuples,
                           StreamProperties props,
                           StreamBaseURI server)

Constructor

Parameters:

tuples - tuples

props - stream properties

server - server URI

Method Detail

getTupleCount

public int getTupleCount()

Description copied from class: DequeueResult

Returns the number of tuples dequeued.

Specified by:

getTupleCount in class DequeueResult

Returns:

number of tuples

iterator

public Iterator<Tuple> iterator()

Description copied from class: DequeueResult

Returns an iterator of all tuples.

Specified by:

iterator in interface Iterable<Tuple>

Specified by:

iterator in class DequeueResult