class RedisStreamReader implements Closeable {

  public byte readByte() throws IOException {
    final byte[] bytes = new byte[1];
    inputStream.read(bytes);
    return bytes[0];
  }

  public  RedisStreamReader(InputStream inputStream);

}