* deduped.
     *
     * TODO: See if duped headers should be preserved on decode and verify.
     */
    private fun assertSetEquals(
      message: String,
      expected: List<Header>,
      observed: List<Header>,
    ) {
      assertThat(LinkedHashSet(observed), message)
        .isEqualTo(LinkedHashSet(expected))
    }
  }

$ adb logcat '*:E' OkHttp:D Http2:D TestRunner:D TaskRunner:D OkHttpTest:D GnssHAL_GnssInterface:F DeviceStateChecker:F memtrack:F
...
01-01 12:53:32.811 10999 11089 D OkHttp  : [49 ms] responseHeadersEnd: Response{protocol=h2, code=200, message=, url=https://1.1.1.1/dns-query?dns=AAABAAABAAAAAAAAA3d3dwhmYWNlYm9vawNjb20AABwAAQ}
01-01 12:53:32.811 10999 11089 D OkHttp  : [49 ms] responseBodyStart
01-01 12:53:32.811 10999 11089 D OkHttp  : [49 ms] responseBodyEnd: byteCount=128

    cli_main = None  # type: ignore


def main() -> None:
    if not cli_main:  # type: ignore[truthy-function]
        message = 'To use the fastapi command, please install "fastapi[standard]":\n\n\tpip install "fastapi[standard]"\n'
        print(message)
        raise RuntimeError(message)  # noqa: B904

        .url("https://localhost:1/")
        .build()
    val interceptorResponse =
      Response
        .Builder()
        .request(request)
        .protocol(Protocol.HTTP_1_1)
        .code(200)
        .message("Intercepted!")
        .body("abc".toResponseBody("text/plain; charset=utf-8".toMediaType()))
        .build()
    client =
      client
        .newBuilder()

async def get_model(model_name: ModelName):
    if model_name is ModelName.alexnet:
        return {"model_name": model_name, "message": "Deep Learning FTW!"}

    if model_name.value == "lenet":
        return {"model_name": model_name, "message": "LeCNN all the images"}

                    .collect(joining(", "));
            String message = String.format(
                    "Expected ProjectBuildingResult to have location <%s> but had locations <%s>",
                    formatLocation(columnNumber, lineNumber), actualLocations);
            assertTrue(false, message);
        }

        return this;
    }

    }

    /**
     * Executes the search log aggregation job.
     * Stores search logs using the SearchLogHelper and returns execution results.
     *
     * @return execution result message, empty if successful or error message if failed
     */
    public String execute() {
        final SearchLogHelper searchLogHelper = ComponentUtil.getSearchLogHelper();

        final StringBuilder resultBuf = new StringBuilder();

            fail("Expected ExtractException");
        } catch (final ExtractException e) {
            assertTrue("Error message should mention ZIP archive", e.getMessage().contains("ZIP archive"));
            assertTrue("Error message should indicate failure",
                    e.getMessage().contains("Failed to extract") || e.getMessage().contains("No entries could be processed"));
        }
    }

    /**

        assertEquals(rootCause, ex3.getCause());
    }

    @Test
    @DisplayName("Should verify error message lookup for known fault codes")
    void testErrorMessageLookup() {
        // Test message lookup using DcerpcException's static method
        String msg1 = DcerpcException.getMessageByDcerpcError(DcerpcError.DCERPC_FAULT_OTHER);

        final Locale locale = ComponentUtil.getRequestManager().getUserLocale();
        final String message = ComponentUtil.getMessageManager().getMessage(locale, "labels.crawling_info_" + getKey());
        if (message == null || message.startsWith("???")) {
            return getKey();
        }
        return message;
    }

    @Override
    public String toString() {