class RedisStreamReader implements Closeable {

  public byte[] read(int length) throws IOException {
    if (length == -1) {
      return null;
    }
    final byte[] bytes = new byte[length];
    inputStream.read(bytes);
    //Remove Carriage Return and Line Feed
    inputStream.read(new byte[2]);
    return bytes;
  }

  public  RedisStreamReader(InputStream inputStream);

}