"write end dead" or "pipe" broken error

[Jimmy Anderson]

I am trying to write a program using the PipedInputStream and PipedOutputStream classes. I either get a "pipe broken" or " write end dead" error. There are four classes in all, the first class Prime I won't include, it simply creates a file and populates it with the first 5 prime numbers. The code follows. Some of the code is commented out because I have been playing around trying to get it to work. Any help as to why it won't work would be appreciated.
Thanks in advance.

import java.io.*;
public class IsPrime extends Thread{
   private DataInputStream in = null;
   private DataOutputStream out = null;
   private boolean gotOne;
   private long prime;
   public IsPrime(DataOutputStream out, DataInputStream in){
      this.out = out;
      this.in = in;
   }
   private boolean isPrime(long factorial){      
      for(int i = 2; i <= factorial; i++){
         if(i % factorial == 0){
            return true;
         }
      }
      return false;
   }
   public void run(){
      boolean EOF = false;
      if(out != null && in != null){
         gotOne = true;
         try{
            while(!EOF){
               prime = in.readLong();
               gotOne = isPrime(prime);
               if(gotOne){
                  out.writeLong(prime);  
                  System.out.println(prime + " is a prime number");
                  out.flush();
               }else{
                  System.out.println(prime + " is not a prime number");
               }  
               //in.close();
               //out.flush();
               //out.close();                  
            } 
         //}catch(InterruptedException e){
             //System.err.println("IsPrime Error: " + e.getMessage());
         }catch(EOFException e){
             EOF = true;               
         }catch(IOException e){
             System.err.println("IsPrime Error: " + e.getMessage());
         }
         
      }
   }
}   
  import java.io.*;
public class Factorial extends Thread{
   private long factorial;
   private long prime;
   
   private DataOutputStream out = null;
   private DataInputStream in = null;
   public Factorial(DataOutputStream out, DataInputStream in){
      this.in = in; 
      this.out = out; 
   }
   private long multiply(long prime){     
         this.prime = prime;      
         for(int i = 2; i <= prime; i++){
            factorial = 1;
            for(int factor = 2; factor <= i; factor++)
               factorial *= factor;
         };
      return factorial;
   }
   public void run(){
      
      long[] primes = new long[5];      
      if(in != null && out != null){
         try{
            //Factorial.connect(IsPrime.out);
            //Factorial.sleep(1000);
            int i = 0;
            while((primes[i] = in.readLong()) != 0){
               primes[i] = in.readLong();
               factorial = multiply(primes[i]);
               out.writeLong(factorial);               
               System.out.println(factorial + " is the factorial of " + primes[i]);
               i++;
            }
           //in.close();
           
         
         }catch(IOException e){
              System.err.println("Factorial Error: " + e.getMessage());
         }catch(ArrayIndexOutOfBoundsException e){
              System.err.println("Factorial Index Out Of Bounds: " + e.getMessage());
         }//catch(InterruptedException e){
              //System.err.println("Factorial Interrupted Exception: " + e.getMessage());
         //}
      }
   }
}
import java.io.*;
public class PipeTest{
    static File primes = new File("C:/j2sdk1.4.1_04/io/primes.dat");        
  
    public static void main(String[] args) throws IOException {
       
       //DataOutputStream out = new DataOutputStream(new FileOutputStream("primes.dat"));          
       Prime write = new Prime();
       write.findPrime(primes);
       //FileInputStream primes = new FileInputStream("primes.dat");
       DataInputStream readPrimes = new DataInputStream(new FileInputStream("primes.dat"));                                
       InputStream in = factorial(isPrime(readPrimes));     
             
    }    
    public static InputStream isPrime(InputStream source) throws IOException {
        DataInputStream in = new DataInputStream(source);
        PipedOutputStream pipeOut = new PipedOutputStream();
        PipedInputStream pipeIn = new PipedInputStream(pipeOut);
        DataOutputStream out = new DataOutputStream(pipeOut);
        new IsPrime(out, in).start();
        
        return pipeIn;
    }
    public static InputStream factorial(InputStream source) throws IOException {
        DataInputStream in = new DataInputStream(source);
        PipedOutputStream pipeOut = new PipedOutputStream();
        PipedInputStream pipeIn = new PipedInputStream(pipeOut);
        DataOutputStream out = new DataOutputStream(pipeOut);
        
        new Factorial(out, in).start();
        return in;
    }   
}

[ February 05, 2004: Message edited by: Jim Yingst ]