}
	err = r.skip(5)
	if err != nil {
		t.Fatal(err)
	}
	names, err = r.readNames(5)
	if err != nil {
		t.Fatal(err)
	}
	want = loadMetacacheSampleNames[10:15]
	if !reflect.DeepEqual(names, want) {
		t.Errorf("got unexpected result: %#v", names)
	}

	err = r.skip(len(loadMetacacheSampleNames))
	if err != io.EOF {
		t.Fatal(err)
	}

            DfsReferralDataInternal combined = first.combine(second);

            assertNotNull(combined);
            assertEquals(10 + 15, combined.getPathConsumed());
        }
    }

    @Nested
    @DisplayName("ToString Tests")
    class ToStringTests {

        @Test

        writeInt2(buffer, offset + 4, nameLen);  // NameOffset
        writeInt2(buffer, offset + 6, nameLen);  // NameLength
        writeInt2(buffer, offset + 8, 0);  // Reserved
        writeInt2(buffer, offset + 10, 32);  // DataOffset
        writeInt4(buffer, offset + 12, 32);  // DataLength
        
        // Name
        System.arraycopy(getName().getBytes(), 0, buffer, offset + 16, nameLen);
        
        // Data

            buffer.putInt(4);
            buffer.putInt(4096);
            byte[] bufferArray = buffer.array();

            // When
            int bytesConsumed = fileFsFullSizeInfo.decode(bufferArray, 10, 32);

            // Then
            assertEquals(32, bytesConsumed);
            assertEquals(2048L * 4 * 4096, fileFsFullSizeInfo.getCapacity());
            assertEquals(1024L * 4 * 4096, fileFsFullSizeInfo.getFree());

    assertNotInterrupted();
  }

  public void testTryAcquireTimeoutNoInterruptExpiredMultiPermit() {
    TimedSemaphore semaphore = TimedSemaphore.createWithDelay(LONG_DELAY_MS);
    semaphore.tryAcquireUnsuccessfully(10, 30);
    assertNotInterrupted();
  }

  public void testTryAcquireTimeoutSingleInterruptNoExpireMultiPermit() {
    TimedSemaphore semaphore = TimedSemaphore.createWithDelay(50);
    requestInterruptIn(10);

    assertNotInterrupted();
  }

  public void testTryAcquireTimeoutNoInterruptExpiredMultiPermit() {
    TimedSemaphore semaphore = TimedSemaphore.createWithDelay(LONG_DELAY_MS);
    semaphore.tryAcquireUnsuccessfully(10, 30);
    assertNotInterrupted();
  }

  public void testTryAcquireTimeoutSingleInterruptNoExpireMultiPermit() {
    TimedSemaphore semaphore = TimedSemaphore.createWithDelay(50);
    requestInterruptIn(10);

    /**
     * Parses the last modified date from a string value.
     * First attempts to parse using Apache DateUtils (which supports RFC 1123, RFC 1036, and ANSI C formats).
     * Falls back to a custom pattern for non-standard formats.
     *
     * @param value The date string to parse
     * @return The parsed date, or null if parsing fails
     */

		batchSizeEnv := target.EnvKafkaBatchSize
		if k != config.Default {
			batchSizeEnv = batchSizeEnv + config.Default + k
		}
		batchSize, err := strconv.ParseUint(env.Get(batchSizeEnv, kv.Get(target.KafkaBatchSize)), 10, 32)
		if err != nil {
			return nil, err
		}

		batchCommitTimeoutEnv := target.EnvKafkaBatchCommitTimeout
		if k != config.Default {
			batchCommitTimeoutEnv = batchCommitTimeoutEnv + config.Default + k
		}

            DateTimeFormatter.ofPattern("EEE, dd MMM yyyy HH:mm:ss zzz", Locale.ENGLISH).withZone(ZoneId.of("GMT"));

    /**
     * Parses the last modified date from a string value.
     * Supports RFC 1123, RFC 1036, and ANSI C date formats.
     * Falls back to a custom pattern for non-standard formats.
     *
     * @param value The date string to parse
     * @return The parsed date, or null if parsing fails
     */

* 🌐 Add German translation for `docs/de/docs/tutorial/response-model.md`. PR [#10345](https://github.com/tiangolo/fastapi/pull/10345) by [@nilslindemann](https://github.com/nilslindemann).
* 🌐 Add German translation for `docs/de/docs/tutorial/extra-models.md`. PR [#10351](https://github.com/tiangolo/fastapi/pull/10351) by [@nilslindemann](https://github.com/nilslindemann).