assertEquals("ok", response.get("status"));
        assertEquals("session-123", response.get("sessionId"));
        assertEquals("Response content", response.get("content"));
        assertTrue(response.containsKey("sources"));
        assertEquals(sources, response.get("sources"));
    }

    @Test
    public void test_createSuccessResponse_nullContent() {

        internal var bazar = "bazar"

        internal fun String.fooExt() {}

        internal fun Int.fooExt() {}

        internal val String.barExt: String
            get() = "bar"

        internal var Int.bazarExt: String
            get() = "bar"
            set(value) = Unit

    """

    @Language("kotlin")
    private
    val publicMembers = """

        fun foo() {}

        val bar = "bar"

      override val nonDefaultValue: SSLSocketFactory =
        object :
          DelegatingSSLSocketFactory(Platform.get().newSslSocketFactory(Platform.get().platformTrustManager())) {}

      override val badValue: SSLSocketFactory =
        object : DelegatingSSLSocketFactory(Platform.get().newSslSocketFactory(Platform.get().platformTrustManager())) {
          override fun configureSocket(sslSocket: SSLSocket): SSLSocket = TODO()
        }

            return (NodeManager) field.get(curlHelper);
        } catch (Exception e) {
            return null;
        }
    }

    private SSLSocketFactory getSSLSocketFactory(CurlHelper curlHelper) {
        try {
            Field field = CurlHelper.class.getDeclaredField("sslSocketFactory");
            field.setAccessible(true);
            return (SSLSocketFactory) field.get(curlHelper);
        } catch (Exception e) {

            setterInfo = classMethodCache.get("set");
        }

        if (setterInfo == null) {
            throw new ComponentConfigurationException(configuration, "Cannot find default setter in " + beanType);
        }

        Object value = defaultValue;
        TypeLiteral<?> paramType = TypeLiteral.get(setterInfo.parameterType);

        if (!paramType.getRawType().isInstance(value)) {

        List<Exception> exceptions = new ArrayList<>();

        // When - Multiple threads get and release buffers
        for (int t = 0; t < threadCount; t++) {
            executor.submit(() -> {
                try {
                    startLatch.await();

                    for (int i = 0; i < opsPerThread; i++) {
                        // Get buffer
                        byte[] buffer = BufferCache.getBuffer();

    for (int i = 0; i < 100; ++i) {
      cache.getUnchecked(10).incrementAndGet();
      ticker.advance(1, MILLISECONDS);
    }

    assertThat(applyCount.get()).isEqualTo(evictionCount.get() + 1);
    int remaining = cache.getUnchecked(10).get();
    assertThat(totalSum.get() + remaining).isEqualTo(100);
  }

  public void testRemovalScheduler_expireAfterWrite() {
    FakeTicker ticker = new FakeTicker();

  }

  @IgnoreJRERequirement // used only when Path is available
  private static final class JavaNioCreator extends TempFileCreator {
    @Override
    File createTempDir() {
      try {
        return java.nio.file.Files.createTempDirectory(
                Paths.get(JAVA_IO_TMPDIR.value()), /* prefix= */ null, directoryPermissions.get())
            .toFile();

		return
	}
	allKeys, _, err := GlobalKMS.ListKeys(ctx, &kms.ListRequest{
		Prefix: r.Form.Get("pattern"),
	})
	if err != nil {
		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
		return
	}

	// Get the cred and owner for checking authz below.
	cred, owner, s3Err := validateAdminSignature(ctx, r, "")
	if s3Err != ErrNone {

from pydantic import BaseModel


class Item(BaseModel):
    name: str
    price: float


app = FastAPI()


@app.get("/default")
def get_default() -> Item:
    return Item(name="widget", price=9.99)


@app.get("/explicit", response_class=JSONResponse)
def get_explicit() -> Item:
    return Item(name="widget", price=9.99)


client = TestClient(app)