}

    @Test
    @DisplayName("MonotonicClock elapsed time should increase")
    void testElapsedTime() throws InterruptedException {
        Duration initial = MonotonicClock.elapsed();
        Thread.sleep(50); // Longer delay for more reliable measurement
        Duration later = MonotonicClock.elapsed();

        assertTrue(later.compareTo(initial) > 0, "Elapsed time should increase");
        assertTrue(

    }

    @Test
    public void test_getIndex() throws Exception {
        List<String> words = new ArrayList<>();
        PopularWordsResponse response = new PopularWordsResponse("my-index", 50, words, 5, new ArrayList<>());

        assertEquals("my-index", response.getIndex());
    }

    @Test
    public void test_getTookMs() throws Exception {
        List<String> words = new ArrayList<>();

		// so decrease the timeout towards 25 % of maximum time spent.
		maxDur = maxDur * 125 / 100

		timeout := atomic.LoadInt64(&dt.timeout)
		if maxDur < time.Duration(timeout) {
			// Move 50% toward the max.
			timeout = (int64(maxDur) + timeout) / 2
		}
		if timeout < dt.minimum {
			timeout = dt.minimum
		}
		atomic.StoreInt64(&dt.timeout, timeout)
	}

	gzip "github.com/klauspost/pgzip"
	"github.com/pierrec/lz4/v4"
)

type countUpReader struct {
	reader    io.Reader
	bytesRead int64
}

// Max bzip2 concurrency across calls. 50% of GOMAXPROCS.
var bz2Limiter = pbzip2.CreateConcurrencyPool((runtime.GOMAXPROCS(0) + 1) / 2)

func (r *countUpReader) Read(p []byte) (n int, err error) {
	n, err = r.reader.Read(p)
	atomic.AddInt64(&r.bytesRead, int64(n))

            handle.setDoReceiveFragmentReturn(50);

            // When: Calling fragment methods
            int sendReceiveResult = handle.doSendReceiveFragment(new byte[10], 0, 10, new byte[100]);
            int receiveResult = handle.doReceiveFragment(new byte[100]);

            // Then: Should return configured values
            assertEquals(100, sendReceiveResult);
            assertEquals(50, receiveResult);
        }

///

## バリデーションの追加

`q`はオプショナルですが、もし値が渡されてきた場合には、**50文字を超えないこと**を強制してみましょう。

### `Query`のインポート

そのために、まずは`fastapi`から`Query`をインポートします:

{* ../../docs_src/query_params_str_validations/tutorial002.py hl[3] *}

## デフォルト値として`Query`を使用

パラメータのデフォルト値として使用し、パラメータ`max_length`を50に設定します:

{* ../../docs_src/query_params_str_validations/tutorial002.py hl[9] *}

    for (int n = 0; n <= 50; n++) {
      for (int k = 0; k <= n; k++) {
        BigInteger expectedBig = BigIntegerMath.binomial(n, k);
        int expectedInt = fitsInInt(expectedBig) ? expectedBig.intValue() : Integer.MAX_VALUE;
        assertEquals(expectedInt, IntMath.binomial(n, k));
      }
    }
  }

  public void testBinomialOutside() {
    for (int i = 0; i <= 50; i++) {
      int n = i;

        // Write structure header (9 bytes)
        SMBUtil.writeInt2(9, buffer, offset); // Structure size
        SMBUtil.writeInt2(80 - 64, buffer, offset + 2); // Buffer offset (relative to header)
        SMBUtil.writeInt4(50, buffer, offset + 4); // Total length of notification data

        // Write notification data at buffer offset 80
        int notifyOffset = 80;

    @Test
    @DisplayName("Should write correct bytes to wire format")
    void testWriteBytesWireFormat() throws Exception {
        // Given
        byte[] buffer = new byte[512];
        int headerStart = 50;
        int bodyOffset = headerStart + Smb2Constants.SMB2_HEADER_LENGTH;

        // Encode the full message to set headerStart
        request.encode(buffer, headerStart);

    }

    @Test
    void testConstructor() {
        // Test that the constructor properly initializes the object
        assertNotNull(response);
        // The command should be SMB_COM_TRANSACTION2 (0x32 = 50)
        assertEquals(ServerMessageBlock.SMB_COM_TRANSACTION2, response.getCommand());
        // The subcommand should be TRANS2_FIND_FIRST2 (0x01 = 1)