Robust/src/ClassLibrary/SocketInputStream.java

   1 public class SocketInputStream extends InputStream {
   2   Socket s;
   3   public SocketInputStream(Socket s) {
   4     this.s=s;
   5   }
   6
   7   public int read() {
   8     byte[] x=new byte[1];
   9     int len=s.read(x);
  10     if (len<=0)
  11       return -1;
  12     else return x[0];
  13   }
  14
  15   public int read(byte[] b) {
  16     return s.read(b);
  17   }
  18
  19   public int readAll(byte[] b) {
  20     int offset=read(b);
  21     if (offset<0)
  22       return offset;
  23     int toread=b.length-offset;
  24     while(toread>0) {
  25       byte[] t=new byte[toread];
  26       int rd=read(t);
  27       if (rd<0)
  28         return rd;
  29       for(int i=0; i<rd; i++)
  30         b[i+offset]=t[i];
  31       offset+=rd;
  32       toread-=rd;
  33     }
  34     return b.length;
  35   }
  36
  37   public void close() {
  38     s.close();
  39   }
  40 }