org.fcrepo.kernel.utils.iterators

Interface IteratorConsumer<E,T>

Type Parameters:

E -

T -

All Known Subinterfaces:

RdfStreamConsumer

All Known Implementing Classes:

PersistingRdfStreamConsumer, RdfAdder, RdfRemover

public interface IteratorConsumer<E,T>

Implemented by something that can consume an Iterator. The assumption is that a reference to the appropriate iterator is managed as part of the state of any implementation.

Since:

Oct 24, 2013

Author:

ajs6f

Method Summary

Methods

Modifier and Type	Method and Description
void	consume() Synchronous consumption.
com.google.common.util.concurrent.ListenableFuture<T>	consumeAsync() Asynchronous consumption.

Method Detail

consume

void consume()
             throws Exception

Synchronous consumption.

Throws:

Exception

consumeAsync

com.google.common.util.concurrent.ListenableFuture<T> consumeAsync()

Asynchronous consumption.

Returns:

ListenableFuture