loader - Code Search

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/tls/BasicTrustRootIndex.kt

 */
package okhttp3.internal.tls

import java.security.cert.X509Certificate
import javax.security.auth.x500.X500Principal

/** A simple index that of trusted root certificates that have been loaded into memory. */
class BasicTrustRootIndex(
  vararg caCerts: X509Certificate,
) : TrustRootIndex {
  private val subjectToCaCerts: Map<X500Principal, Set<X509Certificate>>

  init {

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

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

- 1.8K bytes

- Click Count (0)

github.com/codelibs/fess-crawler

fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/Hc5HttpClient.java

            }
            responseData.setHttpStatusCode(httpStatusCode);
            for (final Header header : response.getHeaders()) {
                responseData.addMetaData(header.getName(), header.getValue());
            }
            responseData.setMimeType(contentType);
            final Header contentLengthHeader = response.getFirstHeader("Content-Length");
            if (contentLengthHeader == null) {

Created: Sun Apr 12 03:50:13 GMT 2026

- Last Modified: Sat Jan 31 12:23:29 GMT 2026

- 62.2K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs/es/docs/tutorial/server-sent-events.md

///

## Reanudar con `Last-Event-ID` { #resuming-with-last-event-id }

Cuando un navegador se reconecta después de una caída de la conexión, envía el último `id` recibido en el header `Last-Event-ID`.

Puedes leerlo como un parámetro de header y usarlo para reanudar el stream desde donde el cliente se quedó:

{* ../../docs_src/server_sent_events/tutorial004_py310.py hl[25,27,31] *}

## SSE con `POST` { #sse-with-post }

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

- Last Modified: Thu Mar 19 18:12:26 GMT 2026

- 5K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs/en/docs/tutorial/server-sent-events.md

///

## Resuming with `Last-Event-ID` { #resuming-with-last-event-id }

When a browser reconnects after a connection drop, it sends the last received `id` in the `Last-Event-ID` header.

You can read it as a header parameter and use it to resume the stream from where the client left off:

{* ../../docs_src/server_sent_events/tutorial004_py310.py hl[25,27,31] *}

## SSE with POST { #sse-with-post }

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

- Last Modified: Thu Mar 05 18:13:19 GMT 2026

- 4.6K bytes

- Click Count (0)

github.com/minio/minio

internal/crypto/sse_test.go

	}
}

var ssecUnsealObjectKeyTests = []struct {
	Headers        http.Header
	Bucket, Object string
	Metadata       map[string]string

	ExpectedErr error
}{
	{ // 0 - Valid HTTP headers and valid metadata entries for bucket/object
		Headers: http.Header{
			"X-Amz-Server-Side-Encryption-Customer-Algorithm": []string{"AES256"},

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

- Last Modified: Tue Jun 01 21:59:40 GMT 2021

- 8.4K bytes

- Click Count (0)

github.com/square/okhttp

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

  @Test fun http2HeadersListDropsForbiddenHeadersHttp2() {
    val request =
      Request
        .Builder()
        .url("http://square.com/")
        .header("Connection", "upgrade")
        .header("Upgrade", "websocket")
        .header("Host", "square.com")
        .header("TE", "gzip")
        .build()
    val expected =
      headerEntries(
        ":method",
        "GET",
        ":path",
        "/",

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

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

- 2.5K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/response_directly/tutorial002_py310.py

from fastapi import FastAPI, Response

app = FastAPI()


@app.get("/legacy/")
def get_legacy_data():
    data = """<?xml version="1.0"?>
    <shampoo>
    <Header>
        Apply shampoo here.
    </Header>
    <Body>
        You'll have to use soap here.
    </Body>
    </shampoo>
    """

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

- Last Modified: Thu Feb 12 13:19:43 GMT 2026

- 354 bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/header_param_models/tutorial001_py310.py

from fastapi import FastAPI, Header
from pydantic import BaseModel

app = FastAPI()


class CommonHeaders(BaseModel):
    host: str
    save_data: bool
    if_modified_since: str | None = None
    traceparent: str | None = None
    x_tag: list[str] = []


@app.get("/items/")
async def read_items(headers: CommonHeaders = Header()):

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

- Last Modified: Tue Sep 17 18:54:10 GMT 2024

- 352 bytes

- Click Count (0)

github.com/minio/minio

cmd/bucket-metadata.go

		b.Created = createdAt.UTC()
	}
}

// Load - loads the metadata of bucket by name from ObjectLayer api.
// If an error is returned the returned metadata will be default initialized.
func readBucketMetadata(ctx context.Context, api ObjectLayer, name string) (BucketMetadata, error) {
	if name == "" {
		internalLogIf(ctx, errors.New("bucket name cannot be empty"), logger.WarningKind)
		return BucketMetadata{}, errInvalidArgument
	}

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

- Last Modified: Sun Sep 28 20:59:21 GMT 2025

- 18.2K bytes

- Click Count (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/app/web/admin/wizard/AdminWizardActionTest.java

        assertEquals("storage://bucket/folder/file.txt", wizardAction.convertCrawlingPath("storage://bucket/folder/file.txt"));
    }

    @Test
    public void test_convertCrawlingPath_s3_protocol() {
        assertEquals("s3://bucket/path", wizardAction.convertCrawlingPath("s3://bucket/path"));
        assertEquals("s3://my-bucket/folder/file.txt", wizardAction.convertCrawlingPath("s3://my-bucket/folder/file.txt"));

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

- Last Modified: Wed Jan 14 14:29:07 GMT 2026

- 9.9K bytes

- Click Count (0)

Search Options