com.simiacryptus.util.io

Class DataLoader<T>

java.lang.Object

com.simiacryptus.util.io.DataLoader<T>

Type Parameters:

T - the type parameter

public abstract class DataLoader<T>
extends Object

The type Data loader.

Constructor Summary

Constructors

Constructor and Description
DataLoader()

Method Summary

Modifier and Type	Method and Description
void	clear() Clear.
protected abstract void	read(List<T> queue) Read.
void	stop() Stop.
Stream<T>	stream() Stream stream.

Methods inherited from class java.lang.Object

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

Constructor Detail

DataLoader

public DataLoader()

Method Detail

clear

public void clear()
           throws InterruptedException

Clear.

Throws:

InterruptedException - the interrupted exception

read

protected abstract void read(List<T> queue)

Read.

Parameters:

queue - the queue

stop

public void stop()

Stop.

stream

public Stream<T> stream()

Stream stream.

Returns:

the stream