RedisStreamReader implements Closeable { public byte readByte() throws IOException { final byte[] bytes = new byte[1]; inputStream.read(bytes); return bytes[0]; } RedisStreamReader(InputStream inputStream); byte readByte(); String readString(); int readInt(); byte[] read(int length); @Override void close(); static final int BUFFER_SIZE; }
@Test public void readByte() throws IOException { final byte theByte = '*'; final byte[] bytes = {theByte}; setupInputStreamRead(bytes, SIZE); byte actualByte = reader.readByte(); assertEquals(theByte, actualByte); }