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 void close() {
  20     s.close();
  21   }
  22 }