Java.io.IOException: Pipe not connected

public  PipedInputStream relayBinary() throws IOException 
    {
	byte[] buf=new byte[1024];
       
	PipedInputStream in=new PipedInputStream();
	PipedOutputStream pipe=new PipedOutputStream(in);
	pipe.connect(in);
	in.connect(pipe);
	
	int n;

	while (true) {
	    n=fromWebBin.read(buf);
	    if (n==-1) break;
	    if (buf[0]==10 && cr) {
	    	sout.write(buf, 1, n-1);
		
		pipe.write(buf, 1, n-1);
		
	    }
	    else {
	    	sout.write(buf, 0, n);
		
		pipe.write(buf, 0, n);
		
	    }
            cr=false;
	}
	pipe.close();
	return in;
    } // !relayBinary

public void envoi_reponseWeb_au_client() {
PipedInputStream pipe = relayBinary();
	
			
InputStreamReader input = new InputStreamReader(pipe);
			
Interpreteur interprete = new Interpreteur(input, url); 
		}
}