inputstreamhandler.java

A framework written in Java for implementing high-level and dynamic languages, compiling them into J

package gnu.jemacs.buffer;
import java.io.*;
import gnu.mapping.*;

/** Insert input from an InputStream into a buffer.
 * This is typically output from an inferior process. */

class InputStreamHandler extends Thread
{
  ProcessMode mode;
  InputStream in;
  BufferWriter wr;
  Reader in_r;
  char[] buffer;

  public InputStreamHandler(InputStream in, ProcessMode mode)
  {
    this.in = in;
    this.in_r = new InputStreamReader(in);
    this.wr = new BufferWriter(mode.processMark, true);
    this.mode = mode;
  }

  public void run()
  {
    try
      {
	buffer = new char[512];
	for (;;)
	  {
	    int avail = in_r.read(buffer);
	    if (avail <= 0)
	      break;
	    wr.buffer = buffer;
	    wr.count = avail;
	    mode.invoke(wr);
	    //wr.write(buffer, 0, avail);
	    //wr.flush();
	  }
	in.close();
      }
    catch (Exception ex)
      {
	throw new WrappedException(ex);
      }
  }
}