org.eclipse.rdf4j.common.iteration

Class TimeLimitIteration<E,X extends Exception>

java.lang.Object

org.eclipse.rdf4j.common.iteration.AbstractCloseableIteration<E,X>

org.eclipse.rdf4j.common.iteration.IterationWrapper<E,X>

org.eclipse.rdf4j.common.iteration.TimeLimitIteration<E,X>

All Implemented Interfaces:

AutoCloseable, CloseableIteration<E,X>, Iteration<E,X>

Direct Known Subclasses:

AbstractParserQuery.QueryInterruptIteration, AbstractParserQuery.QueryInterruptIteration

public abstract class TimeLimitIteration<E,X extends Exception>
extends IterationWrapper<E,X>

Author:

Arjohn Kampman

Field Summary

Fields inherited from class org.eclipse.rdf4j.common.iteration.IterationWrapper

wrappedIter

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TimeLimitIteration(Iteration<? extends E,? extends X> iter, long timeLimit)

Method Summary

Modifier and Type	Method and Description
protected void	handleClose() Closes this Iteration and also closes the wrapped Iteration if it is a CloseableIteration.
boolean	hasNext() Checks whether the wrapped Iteration contains more elements, closing this Iteration when this is not the case.
E	next() Returns the next element from the wrapped Iteration.
void	remove() Removes the last element that has been returned from the wrapped Iteration.
protected abstract void	throwInterruptedException() If the iteration is interrupted by its time limit, this method is called to generate and throw the appropriate exception.

Methods inherited from class org.eclipse.rdf4j.common.iteration.AbstractCloseableIteration

close, isClosed

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeLimitIteration

protected TimeLimitIteration(Iteration<? extends E,? extends X> iter,
                             long timeLimit)

Method Detail

hasNext

public boolean hasNext()
                throws X extends Exception

Description copied from class: IterationWrapper

Checks whether the wrapped Iteration contains more elements, closing this Iteration when this is not the case.

Specified by:

hasNext in interface Iteration<E,X extends Exception>

Overrides:

hasNext in class IterationWrapper<E,X extends Exception>

Returns:

true if the wrapped Iteration contains more elements, false otherwise.

Throws:

X

X extends Exception

next

public E next()
       throws X extends Exception

Description copied from class: IterationWrapper

Returns the next element from the wrapped Iteration.

Specified by:

next in interface Iteration<E,X extends Exception>

Overrides:

next in class IterationWrapper<E,X extends Exception>

Returns:

the next element in the iteration.

Throws:

X extends Exception

remove

public void remove()
            throws X extends Exception

Description copied from class: IterationWrapper

Removes the last element that has been returned from the wrapped Iteration.

Specified by:

remove in interface Iteration<E,X extends Exception>

Overrides:

remove in class IterationWrapper<E,X extends Exception>

Throws:

X extends Exception

handleClose

protected void handleClose()
                    throws X extends Exception

Description copied from class: IterationWrapper

Closes this Iteration and also closes the wrapped Iteration if it is a CloseableIteration.

Overrides:

handleClose in class IterationWrapper<E,X extends Exception>

Throws:

X

X extends Exception

throwInterruptedException

protected abstract void throwInterruptedException()
                                           throws X extends Exception

If the iteration is interrupted by its time limit, this method is called to generate and throw the appropriate exception.

Throws:

X - The generic class of exceptions thrown by this method.

X extends Exception