class RedisStreamWriter implements Closeable {

  public void writeNewLine() throws IOException {
    write(RedisBytes.CARRIAGE_RETURN_BYTE);
    write(RedisBytes.LINE_FEED_BYTE);
  }

  public  RedisStreamWriter(OutputStream outputStream);

}