@Synchronized fun requestCount(): Int = requestCount

  private inner class RealCacheRequest(
    private val editor: DiskLruCache.Editor,
  ) : CacheRequest {
    private val cacheOut: Sink = editor.newSink(ENTRY_BODY)
    private val body: Sink
    var done = false

    init {
      this.body =
        object : ForwardingSink(cacheOut) {
          @Throws(IOException::class)
          override fun close() {

      val length = logMessage.length
      while (i < length) {
        var newline = logMessage.indexOf('\n', i)
        newline = if (newline != -1) newline else length
        do {
          val end = minOf(newline, i + MAX_LOG_LENGTH)
          Log.println(logLevel, tag, logMessage.substring(i, end))
          i = end
        } while (i < newline)
        i++
      }
    }
  }

import (
	"iter"
	"unicode"
	"unicode/utf8"
)

// Lines returns an iterator over the newline-terminated lines in the byte slice s.
// The lines yielded by the iterator include their terminating newlines.
// If s is empty, the iterator yields no lines at all.
// If s does not end in a newline, the final yielded line will not end in a newline.
// It returns a single-use iterator.
func Lines(s []byte) iter.Seq[[]byte] {

            callback.onRetryChange(retryMs)
          }
        }

        -1 -> {
          val lineEnd = source.indexOfElement(CRLF)
          if (lineEnd != -1L) {
            // Skip the line and newline
            source.skip(lineEnd)
            source.select(options)
          } else {
            return false // No more newlines.
          }
        }

        else -> throw AssertionError()
      }

      with(sink) {
        writeInt(totalRuleBytes)
        for (domain in sortedRules) {
          write(domain).writeByte(NEWLINE)
        }
        writeInt(totalExceptionRuleBytes)
        for (domain in sortedExceptionRules) {
          write(domain).writeByte(NEWLINE)
        }
      }
    }
  }

  private suspend fun writeOutputFile(importResults: ImportResults) =

        StringBuilder buf = new StringBuilder();
        Supplier<Object> supplier = () -> "test \"quotes\" and \n newline";

        monitorTarget.append(buf, "specialKey", supplier);
        assertEquals("\"specialKey\":\"test \\\"quotes\\\" and \\n newline\"", buf.toString());
    }

    // Test append method with String containing backslash
    public void test_append_stringWithBackslash() {

        assertEquals(message, exception.getMessage());
    }

    public void test_newlineCharactersInMessage() {
        // Test with newline characters in message
        String message = "LDAP error:\n- Connection failed\n- Invalid credentials\n- Timeout";
        LdapConfigurationException exception = new LdapConfigurationException(message);

        assertSame(inputs, item.getNewInputs());
        assertEquals("result", item.getNewOutput());
    }

    public void test_constructor_withNewlineInOutput() {
        // Test newline replacement in output
        String[] inputs = { "input" };
        CharMappingItem item = new CharMappingItem(1L, inputs, "line1\nline2");

        assertEquals("line1 line2", item.getOutput());
    }

        };
        ComponentUtil.register(mockSearchLogHelper, "searchLogHelper");

        // Execute the job
        String result = aggregateLogJob.execute();

        // Verify result ends with newline even with empty message
        assertNotNull(result);
        assertEquals("\n", result);
    }

    public void test_execute_withNullMessageException() {

        scoreUpdater.addScoreBooster(booster1);
        scoreUpdater.addScoreBooster(booster2);

        String result = scoreUpdater.execute();

        // Check format with class name, colon, count, and newline
        String[] lines = result.split("\n");
        assertEquals(2, lines.length);
        assertTrue(lines[0].matches("TestScoreBooster : \\d+"));
        assertTrue(lines[1].matches("TestScoreBooster : \\d+"));
    }