import net.fs.rudp.UDPOutputStream; //导入依赖的package包/类
public void pipe(InputStream is,UDPOutputStream tos,int initSpeed,final Pipe p2) throws Exception{
	
	int len=0;
	byte[] buf=new byte[100*1024];
	boolean sendeda=false;
	while((len=is.read(buf))>0){
		readed=true;
		if(!sendeda){
			sendeda=true;
		}
		tos.write(buf, 0, len);
	}
}
 

import net.fs.rudp.UDPOutputStream; //导入依赖的package包/类
public void pipe(ClientUI ui,InputStream is,UDPOutputStream tos,int initSpeed,final Pipe p2) throws Exception{
	int len=0;
	byte[] buf=new byte[100*1024];
	boolean sendeda=false;
	while((len=is.read(buf))>0){
		readed=true;
		if(!sendeda){
			sendeda=true;
		}
		tos.write(buf, 0, len);
	}
}
 

import net.fs.rudp.UDPOutputStream; //导入依赖的package包/类
public void pipe(InputStream is, UDPOutputStream tos, int initSpeed, final Pipe p2) throws Exception {

        int len;
        byte[] buf = new byte[100 * 1024];
        boolean sendeda = false;
        while ((len = is.read(buf)) > 0) {
            readed = true;
            if (!sendeda) {
                sendeda = true;
            }
            tos.write(buf, 0, len);
        }
    }