final ResultData resultData = new ResultData();
        final Function<Object, byte[]> serializer = new Function<Object, byte[]>() {
            @Override
            public byte[] apply(Object t) {
                return t.toString().getBytes();
            }
        };

        // ## Act ##
        resultData.setSerializer(serializer);

        // ## Assert ##
        assertNotNull(resultData.serializer);

                final StringBuilder tempBuf = new StringBuilder();
                append(tempBuf, StringEscapeUtils.escapeJson(e.getKey()), () -> StringEscapeUtils.escapeJson(e.getValue().getHotThreads()));
                return tempBuf.toString();
            }).collect(Collectors.joining(","));
            buf.append(hotThreads).append(',');
        } catch (final Exception e) {
            appendException(buf, e).append(',');
        }

     * This is required and limited to 100 characters.
     */
    @Required
    @Size(max = 100)
    public String docId;

    /**
     * Redirect target or return URL parameter.
     * This is required and limited to 10000 characters to accommodate long URLs.
     */
    @Size(max = 10000)
    @Required
    public String rt;

    /**

  @CollectionSize.Require(absent = ZERO)
  public void testSetValue_valueAbsent() {
    for (Entry<K, V> entry : getMap().entrySet()) {
      if (entry.getKey().equals(k0())) {
        assertEquals("entry.setValue() should return the old value", v0(), entry.setValue(v3()));
      }
    }
    expectReplacement(entry(k0(), v3()));
  }

  @MapFeature.Require(SUPPORTS_PUT)
  @CollectionSize.Require(SEVERAL)

    extends PerCollectionSizeTestSuiteBuilder<B, TestCollectionGenerator<E>, Collection<E>, E> {
  @SuppressWarnings("rawtypes") // class literals
  @Override
  protected List<Class<? extends AbstractTester>> getTesters() {
    return Arrays.<Class<? extends AbstractTester>>asList(
        CollectionAddAllTester.class,
        CollectionAddTester.class,
        CollectionClearTester.class,
        CollectionContainsAllTester.class,

    this.mapCache = mapCache;
  }

  @Parameters
  public static Collection<Object[]> parameters() {
    Comparator<String> nullsLast = Ordering.natural().nullsLast();

    return Arrays.asList(
        new Object[][] {
          {new MapIteratorCache<String, String>(new HashMap<String, String>())},
          {new MapIteratorCache<String, String>(new TreeMap<String, String>(nullsLast))},

        bufferIndex += 2;
        if ((this.setupCount != 0) && log.isDebugEnabled()) {
            log.debug("setupCount is not zero: " + this.setupCount);
        }

        return bufferIndex - start;
    }

    public String toString() {
        final int len = length / 2 - (zterm ? 1 : 0);
        final char[] ca = new char[len];
        for (int i = 0; i < len; i++) {
            ca[i] = (char) buffer[i];
        }
        return new String(ca, 0, len);
    }

			if srv := newConsoleServerFn(); srv != nil {
				shutdownLogIf(context.Background(), srv.Shutdown())
			}
		}

		if globalEventNotifier != nil {
			globalEventNotifier.RemoveAllBucketTargets()
		}

		return true
	}

	for {
		select {
		case err := <-globalHTTPServerErrorCh:
			shutdownLogIf(context.Background(), err)
			exit(stopProcess())
		case osSignal := <-globalOSSignalCh:

     */
    @Override
    public void expired() {
        if (clientConnectionManager == null) {
            logger.warn("clientConnectionManager is null.");
            return;
        }

        try {
            // Close expired connections
            clientConnectionManager.closeExpiredConnections();
            // Close idle connections