Source code: Freenet/support/Splitter.java

   package Freenet.support;
   
   import java.io.*;
   import java.util.*;
   
   public class Splitter extends OutputStream implements Runnable
   {
     private Vector outputs=new Vector();
     private Vector writers=new Vector();
    InputStream source;
  
    public Splitter()
    {
      source=null;
    }
  
    public Splitter(InputStream in)
    {
      source=in;
    }
  
    public void split()
    {
      int c;
  
      if(source!=null)
        try
        {
          do
          {
            c=source.read();
            if(c!=-1)
              write(c);
          }
          while(c!=-1);
        }
        catch(IOException e) {}
    }
  
      public void run() {
    split();
      }
  
    public void addoutput(OutputStream out)
    {
      outputs.addElement(out);
    }
  
    public void addwriter(Writer w)
    {
      writers.addElement(w);
    }
  
    public void write(int c)
    {
      int len, x;
      OutputStream current;
      Writer cw;
  
      len=outputs.size();
      if(len!=0)
      {
        x=0;
        while(x<len)
        {
          current=(OutputStream)outputs.elementAt(x);
          try { current.write(c); x=x+1;}
          catch(IOException e) { outputs.removeElementAt(x); len=len-1;}
        }
      }
  
      len=writers.size();
      if(len!=0)
      {
        x=0;
        while(x<len)
        {
          cw=(Writer)writers.elementAt(x);
          try { cw.write(c); x=x+1;}
          catch(IOException e) { writers.removeElementAt(x); len=len-1;}
        }
      }
    }
  }