RedisOutputStream { void flush() throws IOException { if (position > 0) { stream.write(buffer, 0, position); position = 0; } } RedisOutputStream(OutputStream stream, int bufferSize);   }
@Test void flush() throws IOException { stream.flush(); assertEquals("", decode(output.toByteArray())); }