pipe.java

来自「KWIC系统 采用管道/过滤器风格实现」· Java 代码 · 共 47 行

//package kwic.pf;


import java.io.PipedReader;
import java.io.PipedWriter;
import java.io.IOException;


public class Pipe
{

  private PipedReader reader_;
  private PipedWriter writer_;


/* Default constructor. It establishes the connection between the character streams. */


  public Pipe() throws IOException
  {
    writer_ = new PipedWriter();
    reader_ = new PipedReader();
    writer_.connect(reader_);
  }


  public void write(int c) throws IOException
  {
    writer_.write(c);
  }

  public int read() throws IOException{
    return reader_.read();
  }

  public void closeWriter() throws IOException
  {
    writer_.flush();
    writer_.close();
  }

  public void closeReader() throws IOException
  {
    reader_.close();
  }
}