final String str = message.toString();
        assertTrue(str.contains("..."));
        assertTrue(str.length() < longContent.length() + 50);
    }

    @Test
    public void test_toStringNullContent() {
        final LlmMessage message = new LlmMessage("user", null);
        final String str = message.toString();
        assertTrue(str.contains("content='null'"));

    assertThat(j.join(ImmutableMultimap.of("1", "a", "1", "b").entries().iterator()))
        .isEqualTo("1:a;1:b");

    Map<@Nullable String, @Nullable String> mapWithNulls = new LinkedHashMap<>();
    mapWithNulls.put("a", null);
    mapWithNulls.put(null, "b");
    Set<Entry<@Nullable String, @Nullable String>> entriesWithNulls = mapWithNulls.entrySet();

    assertThrows(NullPointerException.class, () -> j.join(entriesWithNulls));

        ndrBuffer.setIndex(0);
        String decodedString = ndrBuffer.dec_ndr_string();
        assertEquals(testString, decodedString);
        assertEquals(expectedLength, ndrBuffer.getIndex());

        // Test empty string
        ndrBuffer.reset();
        String emptyString = "";
        ndrBuffer.enc_ndr_string(emptyString);

)

func TestNSQArgs_Validate(t *testing.T) {
	type fields struct {
		Enable      bool
		NSQDAddress xnet.Host
		Topic       string
		TLS         struct {
			Enable     bool
			SkipVerify bool
		}
	}
	tests := []struct {
		name    string
		fields  fields
		wantErr bool
	}{
		{
			name: "test1_missing_topic",
			fields: fields{
				Enable: true,
				NSQDAddress: xnet.Host{

    pongQueue.add(payload)
    runWriter()
    return true
  }

  override fun close(
    code: Int,
    reason: String?,
  ): Boolean = close(code, reason, webSocketCloseTimeout)

  @Synchronized fun close(
    code: Int,
    reason: String?,
    cancelAfterCloseMillis: Long,
  ): Boolean {
    validateCloseCode(code)

    var reasonBytes: ByteString? = null

     */
    public CurlException(final String message, final Throwable cause) {
        super(message, cause);
    }

    /**
     * Constructs a new CurlException with the specified detail message.
     *
     * @param message the detail message (which is saved for later retrieval by the {@link #getMessage()} method).
     */
    public CurlException(final String message) {
        super(message);
    }

  override fun getSelectedProtocol(sslSocket: SSLSocket): String? {
    val s = sslSocket as BCSSLSocket

    return when (val protocol = s.applicationProtocol) {
      null, "" -> null
      else -> protocol
    }
  }

  override fun configureTlsExtensions(
    sslSocket: SSLSocket,
    hostname: String?,
    protocols: List<Protocol>,
  ) {

    assertThat(headers["c"]).isEqualTo("d")
    assertThat(headers["e"]).isNull()
  }

  @Test fun iteratorOperator() {
    val headers = headersOf("a", "b", "c", "d")

    val pairs = mutableListOf<Pair<String, String>>()
    for ((name, value) in headers) {
      pairs += name to value
    }

    assertThat(pairs).containsExactly("a" to "b", "c" to "d")
  }

  @Test fun builderGetOperator() {

    if (shutdown) throw RejectedExecutionException()
    calls.add(command as RealCall.AsyncCall)
  }

  fun assertJobs(vararg expectedUrls: String) {
    val actualUrls = calls.map { it.request.url.toString() }
    assertThat(actualUrls).containsExactly(*expectedUrls)
  }

  fun finishJob(url: String) {
    val i = calls.iterator()
    while (i.hasNext()) {
      val call = i.next()
      if (call.request.url.toString() == url) {

var _lcEventSrc_index = [...]uint8{0, 4, 8, 15, 20, 25, 37, 48, 61, 72, 84, 109}

func (i lcEventSrc) String() string {
	if i >= lcEventSrc(len(_lcEventSrc_index)-1) {
		return "lcEventSrc(" + strconv.FormatInt(int64(i), 10) + ")"
	}
	return _lcEventSrc_name[_lcEventSrc_index[i]:_lcEventSrc_index[i+1]]