MockResponse
        .Builder()
        .body("A")
        .addHeader("Cache-Control: max-age=30")
        .addHeader("Date: " + formatDate(-31, TimeUnit.MINUTES))
        .build(),
    )
    server.enqueue(
      MockResponse
        .Builder()
        .body("B")
        .addHeader("Cache-Control: max-age=30")
        .addHeader("Date: " + formatDate(0, TimeUnit.MINUTES))
        .build(),
    )

  }

  public void testGet_good() {
    ImmutableDoubleArray iia = ImmutableDoubleArray.of(0, 1, 3);
    assertThat(iia.get(0)).isEqualTo(0.0);
    assertThat(iia.get(2)).isEqualTo(3.0);
    assertThat(iia.subArray(1, 3).get(1)).isEqualTo(3.0);
  }

  public void testGet_bad() {
    ImmutableDoubleArray iia = ImmutableDoubleArray.of(0, 1, 3);
    assertThrows(IndexOutOfBoundsException.class, () -> iia.get(-1));

    }

    public void test_parseTime_validFormat() {
        int[] result = IntervalControlHelper.parseTime("12:30");
        assertEquals(12, result[0]);
        assertEquals(30, result[1]);

        result = IntervalControlHelper.parseTime("00:00");
        assertEquals(0, result[0]);
        assertEquals(0, result[1]);

        result = IntervalControlHelper.parseTime("23:59");

    }

    @Test
    void testGetSyntax() {
        String syntax = srvsvc.getSyntax();
        assertEquals("4b324fc8-1670-01d3-1278-5a47bf6ee188:3.0", syntax);
    }

    @Test
    void testShareInfo0EncodeWithNonNullNetname() throws NdrException {
        srvsvc.ShareInfo0 shareInfo0 = new srvsvc.ShareInfo0();
        shareInfo0.netname = "TestShare";

        SMBUtil.writeInt2(9, buffer, bufferIndex);
        // Write error context and error data
        buffer[bufferIndex + 2] = 1; // Error context count
        buffer[bufferIndex + 3] = 0; // Reserved
        SMBUtil.writeInt4(0, buffer, bufferIndex + 4); // ByteCount (0 for error)

        // Create a custom test response that tracks if readErrorResponse was called

        // Scenario 2: Command timeout
        CommandExecutionException timeout =
                new CommandExecutionException("Command execution timed out after 30 seconds", new RuntimeException("Timeout"));
        assertTrue(timeout.getMessage().contains("timed out"));
        assertNotNull(timeout.getCause());

        // Scenario 3: Permission denied

            final int index = i;
            threads[i] = new Thread(() -> {
                for (int j = 0; j < 10; j++) {
                    try {
                        if ((index + j) % 3 == 0) {
                            // Some failures
                            breaker.call(() -> {
                                throw new RuntimeException("Test");
                            });

// Case 2: bytes=1-10 (absolute start and end offsets) -> RangeSpec{false, 1, 10}
// Case 3: bytes=10- (absolute start offset with end offset unspecified) -> RangeSpec{false, 10, -1}
// Case 4: bytes=-30 (suffix length specification) -> RangeSpec{true, -30, -1}
type HTTPRangeSpec struct {
	// Does the range spec refer to a suffix of the object?
	IsSuffixLength bool

	// Start and end offset specified in range spec

こんにちは、Kaoru FUZITAさん。


@tokyo_bousai
【気象情報】７月３０日（木）１３時５６分現在、気象庁から大雨、洪水警報が発表されています。多摩北部・西部・南部では、低い土地の浸水や河川の増水に警戒してください。http://t.co/SttHvzrWR8
https://twitter.com/tokyo_bousai/status/626620914617024512

@riezo0608
猫を愛する漫画家10人の展覧会「ねこまんてん」
「猫の額」（東京・高円寺）にて7/31～8/12開催予定。
みんにゃ来てね！
http://t.co/t0dkECemdh http://t.co/T4feyVmazB
https://twitter.com/riezo0608/status/626571637073145856

@Mint_Lee

import okhttp3.Headers
import okhttp3.Headers.Companion.headersOf
import okio.Buffer
import okio.ByteString
import org.junit.jupiter.api.Test
import org.junit.jupiter.api.Timeout

@Timeout(30)
class RecordedRequestTest {
  private val headers: Headers = Headers.EMPTY

  @Test fun testIPv4() {
    val socket =
      MockWebServerSocket(
        FakeSocket(