Class Hierarchy
- java.lang.Object
- org.nuxeo.lib.stream.pattern.consumer.internals.AbstractCallablePool<T> (implements java.lang.AutoCloseable)
- org.nuxeo.lib.stream.pattern.consumer.ConsumerPool<M>
- org.nuxeo.lib.stream.pattern.consumer.AbstractConsumer<M> (implements org.nuxeo.lib.stream.pattern.consumer.Consumer<M>)
- org.nuxeo.lib.stream.pattern.consumer.BatchPolicy
- org.nuxeo.lib.stream.pattern.consumer.BatchPolicy.Builder
- org.nuxeo.lib.stream.pattern.consumer.ConsumerPolicy
- org.nuxeo.lib.stream.pattern.consumer.ConsumerPolicyBuilder
- org.nuxeo.lib.stream.pattern.consumer.ConsumerStatus
- org.nuxeo.lib.stream.pattern.consumer.internals.AbstractCallablePool<T> (implements java.lang.AutoCloseable)
Interface Hierarchy
- java.lang.AutoCloseable
- org.nuxeo.lib.stream.pattern.consumer.Consumer<M>
- org.nuxeo.lib.stream.pattern.consumer.ConsumerFactory<M>
Enum Hierarchy
- java.lang.Object
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
- org.nuxeo.lib.stream.pattern.consumer.ConsumerPolicy.StartOffset
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)