}

    assertEquals(1, logHandler.getStoredLogRecords().size());
    assertThat(logHandler.getStoredLogRecords().get(0).getMessage())
        .isEqualTo("Exception while executing callback: MyListener custom-label");
  }

  public void testEnqueueAndDispatch_multithreaded() throws InterruptedException {
    Object listener = new Object();
    ExecutorService service = newFixedThreadPool(4);

	}
}

func TestDeeplyNestedTransactionWithBlockAndWrappedCallback(t *testing.T) {
	transaction := func(ctx context.Context, db *gorm.DB, callback func(ctx context.Context, db *gorm.DB) error) error {
		return db.WithContext(ctx).Transaction(func(tx *gorm.DB) error {
			return callback(ctx, tx)
		})
	}
	var (
		user  = *GetUser("transaction-nested", Config{})
		user1 = *GetUser("transaction-nested-1", Config{})

#   RgavCacheKey                     - BOM import caching (session/soft, typically resolved once)
#   DefaultModelBuilderRequest       - Model building operations (none, ensures fresh dynamic builds)
#   *                                - Fallback for all other requests (request/soft for temporary child request caching)
#
maven.cache.config = \
    SourceCacheKey { scope:session ref:hard } \
    DefaultArtifactResolverRequest { scope:session ref:hard } \

        assertNotNull(firstName, "First called name should not be null");
    }

    @Test
    @DisplayName("nextCalledName should return valid name for fallback attempts")
    void testNextCalledNameContract() {
        // Given
        String expectedNextName = "SERVER15";
        when(mockAddress.nextCalledName(mockContext)).thenReturn(expectedNextName);

        // When

      Request
        .Builder()
        .url(url)
        .build()

    val promise = CompletableFuture<Response>()

    val call = client.newCall(request)
    call.enqueue(
      object : Callback {
        override fun onFailure(
          call: Call,
          e: IOException,
        ) {
          promise.completeExceptionally(e)
        }

        override fun onResponse(

        nestedMap.put("outer", Maps.map("inner", "value").$());
        assertEquals(183L, MemoryUtil.sizeOf(nestedMap));
    }

    @Test
    public void test_sizeOf_customObjects() {
        // Test fallback case for custom objects (should return 16L)
        assertEquals(16L, MemoryUtil.sizeOf(new Object()));
        assertEquals(16L, MemoryUtil.sizeOf(new CustomTestObject()));

            }

            return sanitizedHtml;
        } catch (final Exception e) {
            logger.warn("Failed to render markdown, returning escaped plain text. error={}", e.getMessage());
            // Fallback to escaped plain text
            return escapeHtml(markdown);
        }
    }

    /**
     * Escapes HTML special characters for safe display.
     *
     * @param text the text to escape

MotorClient](https://stackoverflow.com/questions/41584243/runtimeerror-task-attached-to-a-different-loop)), dann denken Sie daran, Objekte zu instanziieren, die einen Event Loop nur innerhalb asynchroner Funktionen benötigen, z. B. einen `@app.on_event("startup")`-Callback.

///...

when using [MongoDB's MotorClient](https://stackoverflow.com/questions/41584243/runtimeerror-task-attached-to-a-different-loop)), remember to instantiate objects that need an event loop only within async functions, e.g. an `@app.on_event("startup")` callback.

///...

        // Test cleanup
        region.close();
        assertFalse(region.isValid(), "Region should be invalid after close");
    }

    @Test
    public void testGetProviderName() {
        assertEquals("TCP Fallback", provider.getProviderName());
    }

    @Test
    public void testGetMaxMessageSize() {
        assertEquals(65536, provider.getMaxMessageSize(), "TCP provider should have 64KB limit");
    }

    @Test