content - Code Search

docs_src/websockets_/tutorial002_py310.py

            <button onclick="connect(event)">Connect</button>
            <hr>
            <label>Message: <input type="text" id="messageText" autocomplete="off"/></label>
            <button>Send</button>
        </form>
        <ul id='messages'>
        </ul>
        <script>
        var ws = null;
            function connect(event) {
                var itemId = document.getElementById("itemId")

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Fri Feb 27 12:34:37 GMT 2026

- 2.7K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/dict/DictionaryManager.java

        });
    }

    /**
     * Gets the HTTP response containing the content of a dictionary file.
     * This method retrieves the raw file content from ConfigSync storage.
     *
     * @param dictFile the dictionary file to retrieve content for
     * @return a CurlResponse containing the file content
     */
    public CurlResponse getContentResponse(final DictionaryFile<? extends DictionaryItem> dictFile) {

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Fri Nov 28 16:29:12 GMT 2025

- 8K bytes

- Click Count (0)

github.com/codelibs/curl4j

src/test/java/org/codelibs/curl/io/ContentCacheTest.java

        tmpFile.deleteOnExit();
        String content = "File content here";
        java.nio.file.Files.write(tmpFile.toPath(), content.getBytes("UTF-8"));
        ContentCache cache = new ContentCache(tmpFile);

        // ## Act ##
        byte[] result = cache.getContentAsBytes();

        // ## Assert ##
        assertEquals(content, new String(result, "UTF-8"));
    }

    @Test

Created: Thu Apr 02 15:34:12 GMT 2026

- Last Modified: Sat Mar 21 09:11:12 GMT 2026

- 15.9K bytes

- Click Count (0)

github.com/square/okhttp

okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourcesHttpTest.kt

        headers = Headers.headersOf("content-type", "application/json"),
      ),
    )
    server.enqueue(
      MockResponse(
        body =
          """
          |data: hey
          |
          |
          """.trimMargin(),
        headers = Headers.headersOf("content-type", "text/event-stream"),
      ),
    )

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Fri Oct 03 07:51:20 GMT 2025

- 3.6K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/index.jsp

<%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%><!DOCTYPE html>
${fe:html(true)}
<head>
<meta charset="utf-8">
<meta name="viewport" content="width=device-width, initial-scale=1">
<meta http-equiv="X-UA-Compatible" content="IE=edge">
<title><la:message key="labels.search_title" /></title>
<c:if test="${osddLink}">
	<link rel="search" type="application/opensearchdescription+xml"
		href="${fe:url('/osdd')}"

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Mon Feb 23 08:03:44 GMT 2026

- 7.3K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/webapp/js/chat.js

                }
            }
        });

        eventSource.addEventListener('chunk', function(e) {
            var data = JSON.parse(e.data);
            if (data.content) {
                responseContent += data.content;
                if (messageElement) {
                    messageElement.find('.message-text').html(renderMarkdown(responseContent));
                    scrollToBottom();
                }

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Thu Mar 19 01:36:02 GMT 2026

- 30.6K bytes

- Click Count (0)

github.com/square/okhttp

docs/recipes.md

=== ":material-language-kotlin: Kotlin"
    ```kotlin
      private val client = OkHttpClient()

      fun run() {

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Sun Mar 15 09:01:42 GMT 2026

- 47.8K bytes

- Click Count (0)

github.com/apache/maven

compat/maven-compat/src/test/java/org/apache/maven/repository/legacy/StringWagon.java

        Resource resource = inputData.getResource();

        String content = expectedContent.get(resource.getName());

        if (content != null) {
            resource.setContentLength(content.length());
            resource.setLastModified(System.currentTimeMillis());

            inputData.setInputStream(new ByteArrayInputStream(content.getBytes(StandardCharsets.UTF_8)));
        } else {

Created: Sun Apr 05 03:35:12 GMT 2026

- Last Modified: Fri Oct 25 12:31:46 GMT 2024

- 3K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/ResponseCommonTest.kt

   * Returns a new response body that refuses to be read once it has been closed. This is true of
   * most [BufferedSource] instances, but not of [Buffer].
   */
  private fun responseBody(content: String): ResponseBody {
    val data = Buffer().writeUtf8(content)
    val source: Source =
      object : Source {
        var closed = false

        override fun close() {
          closed = true
        }

        override fun read(

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Wed Mar 19 19:25:20 GMT 2025

- 3.6K bytes

- Click Count (0)

github.com/minio/minio

internal/bucket/object/lock/lock_test.go

	}{
		{
			metadata: map[string]string{
				"Authorization":        "AWS4-HMAC-SHA256 <cred_string>",
				"X-Amz-Content-Sha256": "",
				"Content-Encoding":     "",
			},
			expected: map[string]string{
				"Authorization":        "AWS4-HMAC-SHA256 <cred_string>",
				"X-Amz-Content-Sha256": "",
				"Content-Encoding":     "",
			},
		},
		{
			metadata: map[string]string{
				"x-amz-object-lock-mode": "governance",

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Fri Aug 29 02:39:48 GMT 2025

- 18.4K bytes

- Click Count (0)

Search Options