docs: @Override
    public synchronized void close() {
      // try to write everything queued / buffered
      for (BatchPoints points : batchQueue) {
        WriteResult result = tryToWrite(points);
        if (result.outcome != WriteResultOutcome.WRITTEN) {
          exceptionHandler.accept(points.getPoints(), result.throwable);
        }
      }
    }