pipetta.java

来自「一个agent 工具包,可以开发移动设备应用,考虑了安全措施」· Java 代码 · 共 51 行

package SOMA.output;

import java.io.*;

public class Pipetta extends Thread
{
  private InputStream in;
  private OutputStream out;

  /**
  * Constructor.
  */
  public Pipetta( InputStream in, OutputStream out )
  {
    super( "[" + in + " ==> " + out + "]" );
    this.in = in;
    this.out = out;
  }

  public void run()
  {
    int i;
    byte[] buff = new byte[200];

    //System.out.println( "Pipetta Avviata" );
    try
    {
      while( (i = in.read( buff )) != -1 )
      {
        //System.out.println( i );
        //System.out.print( i );
        out.write( buff, 0, i );
        out.flush();
        //System.out.print( i );
        //try {Thread.sleep( 5000 );} catch( Exception e ) {}
      }
    }
    catch( Exception e )
    {
      //e.printStackTrace( out );
      try
      {
        out.close();
      }
      catch( Exception f )
      {}
      //e.printStackTrace();
      //System.out.println( "Pipetta.run: Esco" );
    }
  }
}