final int startPosition = params.getStartPosition();
        if (startPosition * 2 >= windowSize) {
            int offset = params.getOffset();
            if (offset < 0) {
                offset = 0;
            } else if (offset > windowSize / 2) {
                offset = windowSize / 2;
            }
            int start = startPosition - offset;
            if (start < 0) {

        return this;
    }

    /**
     * Sets the window size for rescoring.
     * @param windowSize The window size.
     * @return This builder instance.
     */
    public PopularWordsRequestBuilder setWindowSize(final int windowSize) {
        request.setWindowSize(windowSize);
        return this;
    }

    /**
     * Adds an exclude word.
     * @param excludeWord The word to exclude.

    public void setSeed(final String seed) {
        this.seed = seed;
    }

    /**
     * Sets the window size for rescoring.
     * @param windowSize The window size.
     */
    public void setWindowSize(final int windowSize) {
        this.windowSize = windowSize;
    }

    /**
     * Adds a tag to filter by.
     * @param tag The tag.
     */
    public void addTag(final String tag) {

        if (StringUtil.isBlank(modelName)) {
            return null;
        }
        return new QueryRescorerBuilder(new StoredLtrQueryBuilder().modelName(modelName).params(params))
                .windowSize(fessConfig.getLtrWindowSize());
    }

    if (sendConnectionPreface) {
      writer.connectionPreface()
      writer.settings(okHttpSettings)
      val windowSize = okHttpSettings.initialWindowSize
      if (windowSize != DEFAULT_INITIAL_WINDOW_SIZE) {
        writer.windowUpdate(0, (windowSize - DEFAULT_INITIAL_WINDOW_SIZE).toLong())
      }
    }
    // Thread doesn't use client Dispatcher, since it is scoped potentially across clients via

    assertThat(data1.type).isEqualTo(Http2.TYPE_DATA)
    assertThat(data1.streamId).isEqualTo(3)
    assertArrayEquals("abcdef".toByteArray(), data1.data)
  }

  @Test fun readSendsWindowUpdateHttp2() {
    val windowSize = 100
    val windowUpdateThreshold = 50

    // Write the mocking script.
    peer.sendFrame().settings(Settings())
    peer.acceptFrame() // ACK
    peer.acceptFrame() // SYN_STREAM

labels.facet_filetype_pdf=filetype:pdf\t\
labels.facet_filetype_txt=filetype:txt\t\
labels.facet_filetype_others=filetype:others\n\

# ranking

# Window size for rank fusion.
rank.fusion.window_size=200
# Rank constant for rank fusion.
rank.fusion.rank_constant=20
# Number of threads for rank fusion.
rank.fusion.threads=-1
# Score field for rank fusion.
rank.fusion.score_field=rf_score

# acl

    /**
     * Get the value for the key 'rank.fusion.window_size'. <br>
     * The value is, e.g. 200 <br>
     * comment: Window size for rank fusion.
     * @return The value of found property. (NotNull: if not found, exception but basically no way)
     */
    String getRankFusionWindowSize();

    /**
     * Get the value for the key 'rank.fusion.window_size' as {@link Integer}. <br>
     * The value is, e.g. 200 <br>