@Override
    public int end() {
      return matcher.end();
    }

    @Override
    public int start() {
      return matcher.start();
    }
  }

  @J2ktIncompatible private static final long serialVersionUID = 0;

  @Generates
  Integer generateInteger() {
    return new Integer(generateInt());
  }

  @Generates
  long generateLong() {
    return generateInt();
  }

  @SuppressWarnings("removal") // b/321209431 -- maybe just use valueOf here?
  @Generates
  Long generateLongObject() {
    return new Long(generateLong());
  }

  @Generates
  float generateFloat() {
    return generateInt();
  }

   *
   * <p>This method refines {@link Collection#remove} to further specify that it <b>may not</b>
   * throw an exception in response to {@code element} being null or of the wrong type.
   *
   * <p>To both remove the element and obtain the previous count of that element, use {@link
   * #remove(Object, int) remove}{@code (element, 1)} instead.
   *

    protected void setupListCondition(final BadWordCB cb, final BadWordPager badWordPager) {
        if (badWordPager.id != null) {
            cb.query().docMeta().setId_Equal(badWordPager.id);
        }
        // TODO Long, Integer, String supported only.

        // setup condition
        cb.query().addOrderBy_SuggestWord_Asc();

        // search

    }

    /**
     * Imports bad words from a CSV file.

    }

    @Test
    public void test_convertPhraseQuery_longPhrase() {
        // Test with long phrase (many terms)
        PhraseQuery.Builder builder = new PhraseQuery.Builder();
        String[] words = { "this", "is", "a", "very", "long", "phrase", "query" };
        for (String word : words) {
            builder.add(new Term(Constants.DEFAULT_FIELD, word));
        }

   *
   * Use this to monitor backpressure and avoid exceeding the 16 MiB outgoing message buffer limit.
   * When that limit is exceeded, the web socket is gracefully shut down.
   */
  fun queueSize(): Long

  /**
   * Attempts to enqueue `text` to be UTF-8 encoded and sent as a the data of a text (type `0x1`)
   * message.
   *

            return new Iterator<Integer>() {
              @Override
              public void remove() {
                // Wrong exception type.
                throw new IllegalArgumentException();
              }

              @Override
              public Integer next() {
                // Wrong exception type.
                throw new UnsupportedOperationException();
              }

              @Override

                // Too short for TOK_ID + MECH_OID_LEN
                Arguments.of("too short header", new byte[] { 0x04, 0x01, 0x00 }, IllegalArgumentException.class),

                // Wrong TOK_ID
                Arguments.of("wrong TOK_ID", new byte[] { 0x00, 0x02, 0x00, 0x01 }, IllegalArgumentException.class),

                // OID length claims more than available

        final IndexResponse response = builder.execute().actionGet(indexTimeout);
        final long seqNo = response.getSeqNo();
        if (seqNo != SequenceNumbers.UNASSIGNED_SEQ_NO) {
            esEntity.asDocMeta().seqNo(seqNo);
        }
        final long primaryTerm = response.getPrimaryTerm();
        if (primaryTerm != SequenceNumbers.UNASSIGNED_PRIMARY_TERM) {

    assertEquals(Integer.valueOf(0), ArbitraryInstances.get(int.class));
    assertEquals(Integer.valueOf(0), ArbitraryInstances.get(Integer.class));
    assertEquals(Long.valueOf(0), ArbitraryInstances.get(long.class));
    assertEquals(Long.valueOf(0), ArbitraryInstances.get(Long.class));
    assertEquals(Float.valueOf(0), ArbitraryInstances.get(float.class));
    assertEquals(Float.valueOf(0), ArbitraryInstances.get(Float.class));