cascading-protobuf/src/main/java/com/twitter/elephantbird/cascading/protobuf/ProtobufComparator.java
public static void readFully(InputStream in, ByteArrayOutputStream out, byte[] buffer) {
    try {
      int numRead = 0;
      while ((numRead = in.read(buffer, 0, buffer.length)) != -1) {
        out.write(buffer, 0, numRead);
      }
      out.flush();
    } catch (IOException e) {
      throw new RuntimeException(e);
    }
  }
public static void readFully(InputStream in, ByteArrayOutputStream out, byte[] buffer) {
    try {
      int numRead = 0;
      while ((numRead = in.read(buffer, 0, buffer.length)) != -1) {
        out.write(buffer, 0, numRead);
      }
      out.flush();
    } catch (IOException e) {
      throw new RuntimeException(e);
    }
  }
public static void readFully ( InputStream in , ByteArrayOutputStream out , byte [ ] buffer ) { try { int numRead = 0 ; while ( ( numRead = in . read ( buffer , 0 , buffer . length ) ) != - 1 ) { out . write ( buffer , 0 , numRead ) ; } out . flush ( ) ; } catch ( IOException e ) { throw new RuntimeException ( e ) ; } }
Method used to read a protobuf input stream into a byte array
@param in the protobuf input stream
@param out the byte output stream
@param buffer the array out output bytes
Method used to read a protobuf input stream into a byte array