Source code: Freenet/support/Funnel.java

   
   package Freenet.support;
   
   import java.io.*;
   import java.util.*;
   
   public class Funnel extends InputStream
   {
     private Vector inputs=new Vector();
    OutputStream dest;
  
    public Funnel()
    {
      dest=null;
    }
  
    public Funnel(OutputStream out)
    {
      dest=out;
    }
  
    public void funnel()
    {
      int c;
  
      if(dest!=null)
        try
        {
          do
          {
            c=read();
            if(c!=-1)
              dest.write(c);
          }
          while(c!=-1);
        }
        catch(IOException e) {}
    }
  
    public void addinput(InputStream in)
    {
      inputs.addElement(in);
    }
  
    public void addreader(Reader r)
    {
      inputs.addElement(r);
    }
  
    public int read()
    {
      int c;
  
      if(inputs.size()==0)
        return -1;
      Object o=inputs.firstElement();
      if(o instanceof Reader)
      {
        Reader curreader=(Reader)o;
        if(curreader==null) return -1;
        try{ c=curreader.read(); if(c==-1) throw new IOException(); return c;}
        catch(IOException e)
        {
          inputs.removeElement(curreader);
          return read();
        }
      }
      else
      {
        InputStream current=(InputStream)o;
        if(current==null) return -1;
        try{ c=current.read(); if(c==-1) throw new IOException(); return c;}
        catch(IOException e)
        {
          inputs.removeElement(current);
          return read();
        }
      }
    }
  }