import nl.iobyte.datastream.interfaces.IExecutor;

public class MyExecutor implements IExecutor {
    
    public void async(Runnable r) {
        //TODO schedule task
    }
    
}

import nl.iobyte.datastream.interfaces.DataProvider;

import java.util.List;

public class MyDataProvider implements DataProvider<MyClass> {
    
    public List<MyClass> page(int i, int size) {
        //page indexes start with 0 to max page - 1
        //size is how many items per page, if we don't want to use it just ignore it
        
        //TODO Retrieve and parse page
        
        return list; //Return list of parsed data here
    }
    
}

MyExecutor executor = ....;
MyDataProvider provider = ...;

DataStream<MyClass> stream = new DataStream(
        provider,
        executor,
        10, //Page size, must be bigger than minimum entries
        3 //Entries in queue at which to start loading the next page
);

//Take a single vallue
MyClass entry = stream.next(5, TimeUnit.SECONDS); //Specify after how long to timeout if no values loaded

Iterator<MyClass> iterator = stream.iterator(5, TimeUnit.SECONDS); //Specify after how long to timeout if no values loaded

for(MyClass entry : stream.iterate(5, TimeUnit.SECONDS))//Specify after how long to timeout if no values loaded
    //TODO do something with my entry