|
||||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |
Interface Summary | |
---|---|
Consumer<T> | General interface for components able to consume data from any specific resource or stream, following the Producer-Consumer design pattern. |
Producer<T> | A producer implementation that follows the idea of the Producer-Consumer design pattern. |
ProvidesTotalHint | Object provides a hint on total amount of elements it has/can process |
Class Summary | |
---|---|
AbstractConsumer<T,P> | Base implementation of Consumer . |
CompositeProducer<T> | Implementation of Producer to expose streams from several producers as a
single data feed. |
ConsumerIterator<T> | Implementation of Iterator that takes its elements from a Consumer
. |
ListableObjectStoreProducer<T extends Serializable> | Implementation of Producer to stream the contents of a
ListableObjectStore |
ListConsumer<T> | Implementation of Consumer that obains a List
from a Producer and returns the elements one by one. |
PagingConfiguration | Inmutable pojo to carry pagination parameters |
PagingDelegate<T> | A PagingDelegate is a Closeable capable of consuming a data feed in pages. |
PagingDelegateProducer<T> | Implementation of Producer that uses an instance of PagingDelegate
to get its results |
PagingDelegateWrapper<T> | This implementation of PagingDelegate takes care of enforcing some basic
behaviour of the delegate contract so that users don't have to. |
QueueProducer<T> | Implementation of Producer to stream the contents of a
Queue A polling timeout value might be specified,
otherwise the default value of 5000 milliseconds will be assumed |
SimpleConsumer<T> | Basic implementation of Consumer that simply returns the objects returned
by the underlying Producer |
Exception Summary | |
---|---|
ClosedConsumerException | Exception to signal that a consumer you're trying to access is already closed |
|
||||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |