leader - Code Search

okhttp-sse/src/main/kotlin/okhttp3/sse/EventSources.kt

  @JvmStatic
  fun createFactory(callFactory: Call.Factory): EventSource.Factory =
    EventSource.Factory { request, listener ->
      val actualRequest =
        if (request.header("Accept") == null) {
          request.newBuilder().addHeader("Accept", "text/event-stream").build()
        } else {
          request
        }

      RealEventSource(actualRequest, listener).apply {

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

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

- 1.6K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/dashboard/admin_dashboard.jsp

    <jsp:include page="/WEB-INF/view/common/admin/head.jsp"></jsp:include>
</head>
<body class="hold-transition sidebar-mini">
<div class="wrapper">
    <jsp:include page="/WEB-INF/view/common/admin/header.jsp"></jsp:include>
    <jsp:include page="/WEB-INF/view/common/admin/sidebar.jsp">
        <jsp:param name="menuCategoryType" value="dashboard"/>
        <jsp:param name="menuType" value="dashboard"/>
    </jsp:include>

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

- Last Modified: Thu Nov 13 05:54:52 GMT 2025

- 1.2K bytes

- Click Count (0)

github.com/minio/minio

cmd/api-errors.go

	},
	ErrMissingContentLength: {
		Code:           "MissingContentLength",
		Description:    "You must provide the Content-Length HTTP header.",
		HTTPStatusCode: http.StatusLengthRequired,
	},
	ErrMissingContentMD5: {
		Code:           "MissingContentMD5",
		Description:    "Missing or invalid required header for this request: Content-Md5 or Amz-Content-Checksum",
		HTTPStatusCode: http.StatusBadRequest,
	},
	ErrMissingSecurityHeader: {

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

- Last Modified: Wed Apr 16 07:34:24 GMT 2025

- 93K bytes

- Click Count (3)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt

    /**
     * Returns the subset of the headers in [requestHeaders] that impact the content of the
     * response's body.
     */
    private fun varyHeaders(
      requestHeaders: Headers,
      responseHeaders: Headers,
    ): Headers {
      val varyFields = responseHeaders.varyFields()
      if (varyFields.isEmpty()) return Headers.EMPTY

      val result = Headers.Builder()

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

- Last Modified: Fri Mar 20 09:13:37 GMT 2026

- 26.9K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Writer.kt

        length = 0,
        type = TYPE_SETTINGS,
        flags = FLAG_ACK,
      )
      sink.flush()
    }
  }

  /**
   * HTTP/2 only. Send a push promise header block.
   *
   * A push promise contains all the headers that pertain to a server-initiated request, and a
   * `promisedStreamId` to which response frames will be delivered. Push promise frames are sent as

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

- Last Modified: Wed May 28 23:28:25 GMT 2025

- 11K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/io/CharSink.java

import com.google.common.annotations.J2ktIncompatible;
import com.google.errorprone.annotations.CanIgnoreReturnValue;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.Reader;
import java.io.Writer;
import java.nio.charset.Charset;
import java.util.Iterator;
import java.util.stream.Stream;

/**

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Apr 14 16:07:06 GMT 2025

- 6.7K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs/de/docs/how-to/custom-request-and-route.md

///

Zuerst erstellen wir eine `GzipRequest`-Klasse, welche die Methode `Request.body()` überschreibt, um den Body bei Vorhandensein eines entsprechenden Headers zu dekomprimieren.

Wenn der Header kein `gzip` enthält, wird nicht versucht, den Body zu dekomprimieren.

Auf diese Weise kann dieselbe Routenklasse gzip-komprimierte oder unkomprimierte Requests verarbeiten.

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

- Last Modified: Thu Mar 19 17:58:09 GMT 2026

- 5.6K bytes

- Click Count (0)

github.com/minio/minio

cmd/warm-backend-s3.go

	destObj := object
	if s3.Prefix != "" {
		destObj = fmt.Sprintf("%s/%s", s3.Prefix, object)
	}
	return destObj
}

func (s3 *warmBackendS3) PutWithMeta(ctx context.Context, object string, r io.Reader, length int64, meta map[string]string) (remoteVersionID, error) {
	res, err := s3.client.PutObject(ctx, s3.Bucket, s3.getDest(object), r, length, minio.PutObjectOptions{
		SendContentMd5: true,
		StorageClass:   s3.StorageClass,

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

- Last Modified: Sun Jun 08 16:13:30 GMT 2025

- 5.8K bytes

- Click Count (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/orig/view/error/notFound.jsp

<link href="${fe:url('/css/style.css')}" rel="stylesheet"
	type="text/css" />
<link href="${fe:url('/css/font-awesome.min.css')}"
	rel="stylesheet" type="text/css" />
</head>
<body class="error">
	<jsp:include page="../header.jsp" />
	<main class="container">
		<div class="text-center">
			<h2>
				<la:message key="labels.page_not_found_title" />
			</h2>
			<div>
				<la:message key="labels.check_url" />
				<br /> ${f:h(url)}

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

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

- 1.5K bytes

- Click Count (0)

github.com/minio/minio

internal/s3select/parquet/args.go

package parquet

import "encoding/xml"

// ReaderArgs - represents elements inside <InputSerialization><Parquet/> in request XML.
type ReaderArgs struct {
	unmarshaled bool
}

// IsEmpty - returns whether reader args is empty or not.
func (args *ReaderArgs) IsEmpty() bool {
	return !args.unmarshaled
}

// UnmarshalXML - decodes XML data.
func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {

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

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

- 1.4K bytes

- Click Count (0)

Search Options