convert - Code Search

internal/etag/reader.go

//	encryptedContent := Encrypt(compressedContent)
//
//	// Now, we need an io.Reader that can access
//	// the ETag computed over the content.
//	reader := etag.Wrap(encryptedContent, content)
func Wrap(wrapped, content io.Reader) io.Reader {
	if t, ok := content.(Tagger); ok {
		return wrapReader{
			Reader: wrapped,
			Tagger: t,
		}
	}
	return wrapReader{
		Reader: wrapped,
	}
}

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

- Last Modified: Sun Mar 30 00:56:02 GMT 2025

- 4.8K bytes

- Click Count (0)

github.com/square/okhttp

mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

        }
      }
    }
  }

  @Throws(Exception::class)
  private fun processHandshakeFailure(raw: Socket) {
    val context = SSLContext.getInstance("TLS")
    context.init(null, arrayOf<TrustManager>(UNTRUSTED_TRUST_MANAGER), SecureRandom())
    val sslSocketFactory = context.socketFactory
    val socket =
      sslSocketFactory.createSocket(
        raw,
        raw.inetAddress.hostAddress,
        raw.port,

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

- Last Modified: Tue Jan 27 09:00:39 GMT 2026

- 40.3K bytes

- Click Count (0)

github.com/tiangolo/fastapi

tests/test_default_response_class.py


def test_router_a_a_override():
    with client:
        response = client.get("/a/a/override")
    assert response.content == b"Hello A A"
    assert response.headers["content-type"] == text_type


def test_router_a_b():
    with client:
        response = client.get("/a/b")
    assert response.content == b"Hello A B"
    assert response.headers["content-type"] == text_type

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

- Last Modified: Sun Mar 01 20:49:20 GMT 2020

- 5.2K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/test/java/jcifs/pac/kerberos/KerberosTokenTest.java

        // Write length
        if (content.length < 128) {
            baos.write(content.length);
        } else if (content.length < 256) {
            baos.write(0x81); // length of length = 1
            baos.write(content.length);
        } else {
            baos.write(0x82); // length of length = 2
            baos.write((content.length >> 8) & 0xFF);
            baos.write(content.length & 0xFF);
        }

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Thu Aug 14 05:31:44 GMT 2025

- 6.8K bytes

- Click Count (0)

github.com/apache/maven

compat/maven-builder-support/src/main/java/org/apache/maven/building/StringSource.java

     *
     * @param content The String representation, may be empty or {@code null}.
     * @param location The location to report for this use, may be {@code null}.
     */
    public StringSource(CharSequence content, String location) {
        this.content = (content != null) ? content.toString() : "";
        this.location = (location != null) ? location : "(memory)";
        this.hashCode = this.content.hashCode();
    }

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

- Last Modified: Wed Jan 15 18:51:29 GMT 2025

- 3K bytes

- Click Count (0)

github.com/minio/minio

internal/dsync/dsync_test.go

	dm.Unlock(t.Context())
}

func TestSimpleLockUnlockMultipleTimes(t *testing.T) {
	dm := NewDRWMutex(ds, "test")

	dm.Lock(id, source)
	time.Sleep(time.Duration(10+(rand.Float32()*50)) * time.Millisecond)
	dm.Unlock(t.Context())

	dm.Lock(id, source)
	time.Sleep(time.Duration(10+(rand.Float32()*50)) * time.Millisecond)
	dm.Unlock(t.Context())

	dm.Lock(id, source)

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

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

- 10.8K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/opensearch/config/cbean/cq/bs/BsRelatedContentCQ.java

        return this;
    }

    public void setContent_Equal(String content) {
        setContent_Term(content, null);
    }

    public void setContent_Equal(String content, ConditionOptionCall<TermQueryBuilder> opLambda) {
        setContent_Term(content, opLambda);
    }

    public void setContent_Term(String content) {
        setContent_Term(content, null);
    }

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

- Last Modified: Sat Mar 15 06:53:53 GMT 2025

- 63.8K bytes

- Click Count (1)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/job/IndexExportJobTest.java

        assertTrue(content.contains("<html lang=\"ja\">"));
    }

    @Test
    public void test_exportDocument_createsDirectories() {
        final Map<String, Object> source = new LinkedHashMap<>();
        source.put("url", "https://example.com/a/b/c/deep.html");
        source.put("title", "Deep");
        source.put("content", "Content");

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

- Last Modified: Sun Mar 15 09:08:38 GMT 2026

- 66.1K bytes

- Click Count (0)

github.com/apache/maven

api/maven-api-core/src/main/java/org/apache/maven/api/plugin/Log.java

     *
     * @param content the message to log
     */
    void debug(CharSequence content);

    /**
     * Sends a message (and accompanying exception) to the user in the <b>debug</b> error level.
     * The error's stacktrace will be output when this error level is enabled.
     *
     * @param content the message to log
     * @param error the error that caused this log
     */

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

- Last Modified: Sat Sep 28 09:03:24 GMT 2024

- 5.4K bytes

- Click Count (0)

github.com/apache/maven

compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/logging/SystemStreamLog.java

     */
    @Override
    public void debug(CharSequence content) {
        print("debug", content);
    }

    /**
     * @see org.apache.maven.plugin.logging.Log#debug(java.lang.CharSequence, java.lang.Throwable)
     */
    @Override
    public void debug(CharSequence content, Throwable error) {
        print("debug", content, error);
    }

    /**

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

- Last Modified: Fri Jun 06 14:28:57 GMT 2025

- 5.3K bytes

- Click Count (0)

Search Options