groovy/modules/process/src/main/com/baulsupp/groovy/groosh/GridClosureProcess.java

package com.baulsupp.groovy.groosh;

import java.util.Arrays;
import java.util.List;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.io.Writer;
import java.util.ArrayList;

import groovy.lang.Closure;

public class GridClosureProcess extends StreamClosureProcess {
  public GridClosureProcess(Closure closure) {
    super(closure);
  }

  protected void process(final InputStream is, final OutputStream os) throws IOException {
    BufferedReader ris = new BufferedReader(new InputStreamReader(is));
    Writer wos = new PrintWriter(new OutputStreamWriter(os, "ISO-8859-1"));
    
    String line;
    
    List l = new ArrayList();
    
    while ((line = ris.readLine()) != null) {
      String[] content = line.split("\\s+");
      List contentList = Arrays.asList(content);
      
      l.clear();
      l.add(contentList);
      l.add(wos);
      closure.call(l);
      wos.flush();
    }
  }
}