docs: private void blockIfNecessary() {
          if (diskPermits == null || diskLimit == Long.MAX_VALUE)
              return;
          try {
              diskPermits.acquire();
          } catch (InterruptedException e) {
              // don't want to re-interrupt so it won't cause SDK stream to be
              // closed in case the thread is reused for a different request
              throw new AbortedException(e);
          }
      }