docs: @Override
      public void setException(Exception e) {
          if (!isTerminated()) {
              subject.onError(e);
          } else {
              throw new IllegalStateException("Response has already terminated so exception can not be set", e);
          }
      }