Instead of having your input filter return the whole set of records have it just return a single record each time. So everytime its called it gets the next record and if its out of records it returns false. Then you could do something like

 while ($new = Input::X::read()) {
    print Output::Y::get_output ($new); }
}
[download]

Your output filter needs to expect a single record in that case as well.