// NPE on null listener, so we propagate that contract up into the add method as well.
    checkNotNull(runnable, "Runnable was null.");
    checkNotNull(executor, "Executor was null.");

    // Lock while we check state. We must maintain the lock while adding the new pair so that
    // another thread can't run the list out from under us. We only add to the list if we have not
    // yet started execution.
    synchronized (this) {

    //                                                                              ======
    @Override
    protected int delegateSelectCountUniquely(final ConditionBean cb) {
        // #pending check response and cast problem
        final SearchRequestBuilder builder = client.prepareSearch(asEsIndex());
        final EsAbstractConditionBean esCb = (EsAbstractConditionBean) cb;
        if (esCb.getPreference() != null) {

        getMockRequest().setLocale(Locale.JAPANESE);
        helpUrl = systemHelper.getHelpUrl("https://example.com/{lang}/{version}/test.html");
        // Check if Japanese is actually supported or just use the fallback
        assertTrue(helpUrl.contains("98.76"));

        getMockRequest().setLocale(Locale.ITALIAN);

            if (value == null) {
                // If not found, it means ComponentUtil.getSystemProperties() is not returning system properties
                // In that case, just check that the file was created
                assertTrue(propFile.exists());
            } else {
                assertEquals("test.value", value);
            }
        }

        // Clean up

    receivedPongCount++
    awaitingPong = false
  }

  override fun onReadClose(
    code: Int,
    reason: String,
  ) {
    require(code != -1)

    synchronized(this) {
      check(receivedCloseCode == -1) { "already closed" }
      receivedCloseCode = code
      receivedCloseReason = reason
    }

    listener.onClosing(this, code, reason)
  }

  }

  /*
   * Whenever an implementation uses `instanceof` on a parameter instance, the test has to know that
   * (so much for "black box") and try instances that both do and don't pass the check. The "don't"
   * half of that is more awkward to arrange...
   */
  private static <T> Iterable<T> iterable(Collection<T> collection) {
    // return collection::iterator;
    return new Iterable<T>() {

        bb.put(expectedPath.getBytes(StandardCharsets.UTF_16LE));
        bb.putShort((short) 0); // null terminator

        // Decode
        referral.decode(testBuffer, 0, testBuffer.length);

        // Check
        assertEquals(3, referral.getVersion());
        assertEquals(100, referral.getSize());
        assertEquals(expectedPath, referral.getRpath());
        assertNull(referral.getAltPath());

	// and body are traced.
	traceHdrsS3HFlag

	// when provided, disables throttling via the `maxClients` middleware.
	noThrottleS3HFlag
)

func (h s3HFlag) has(flag s3HFlag) bool {
	// Use bitwise-AND and check if the result is non-zero.
	return h&flag != 0
}

// s3APIMiddleware - performs some common handler functionality for S3 API
// handlers.
//

            System.arraycopy(buffer, bufferIndex, this.txn_buf, this.bufDataStart + this.dataDisplacement, this.dataCount);
            bufferIndex += this.dataCount;
        }

        /*
         * Check to see if the entire transaction has been
         * read. If so call the read methods.
         */

        if (!this.parametersDone && this.parameterDisplacement + this.parameterCount == this.totalParameterCount) {

        int written = request.writeBytesWireFormat(buffer, 0);

        // Should write exactly 56 bytes (structure size without data)
        assertEquals(56, written);
        // Check structure size (first 2 bytes should be 57)
        assertEquals(57, (buffer[0] & 0xFF) | ((buffer[1] & 0xFF) << 8));
    }

    @Test
    @DisplayName("Test writeBytesWireFormat with input data")