nobody - Code Search

internal/config/identity/openid/providercfg.go

	}

	client := &http.Client{
		Transport: transport,
	}

	resp, err := client.Do(req)
	if err != nil {
		return nil, err
	}

	defer xhttp.DrainBody(resp.Body)
	if resp.StatusCode != http.StatusOK {
		// uncomment this for debugging when needed.
		// reqBytes, _ := httputil.DumpRequest(req, false)
		// fmt.Println(string(reqBytes))

Registered: Sun Dec 28 19:28:13 UTC 2025

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

- 4.7K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs_src/websockets/tutorial001_py39.py

from fastapi import FastAPI, WebSocket
from fastapi.responses import HTMLResponse

app = FastAPI()

html = """
<!DOCTYPE html>
<html>
    <head>
        <title>Chat</title>
    </head>
    <body>
        <h1>WebSocket Chat</h1>
        <form action="" onsubmit="sendMessage(event)">
            <input type="text" id="messageText" autocomplete="off"/>
            <button>Send</button>
        </form>
        <ul id='messages'>

Registered: Sun Dec 28 07:19:09 UTC 2025

- Last Modified: Wed Dec 17 20:41:43 UTC 2025

- 1.4K bytes

- Viewed (0)

github.com/minio/minio

internal/config/identity/plugin/config.go

		return AuthNResponse{}, err
	}
	defer o.args.CloseRespFn(resp.Body)
	reqDurNanos := time.Since(reqStartTime).Nanoseconds()
	o.serviceMetrics.accumRequestRTT(reqStartTime, float64(reqDurNanos)/1e6, true)

	switch resp.StatusCode {
	case 200:
		var result AuthNSuccessResponse
		if err = json.NewDecoder(resp.Body).Decode(&result); err != nil {
			return AuthNResponse{}, err
		}

Registered: Sun Dec 28 19:28:13 UTC 2025

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

- 13.3K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs/de/docs/_llm-test.md

* die Error-Response

* die Pfadoperation
* der Pfadoperation-Dekorator
* die Pfadoperation-Funktion

* der Body
* der Requestbody
* der Responsebody
* der JSON-Body
* der Formularbody
* der Dateibody
* der Funktionskörper

* der Parameter
* der Body-Parameter
* der Pfad-Parameter
* der Query-Parameter
* der Cookie-Parameter
* der Header-Parameter
* der Formular-Parameter

Registered: Sun Dec 28 07:19:09 UTC 2025

- Last Modified: Wed Dec 17 07:17:04 UTC 2025

- 12.6K bytes

- Viewed (0)

github.com/square/okhttp

okhttp-testing-support/src/main/kotlin/okhttp3/internal/duplex/AsyncRequestBody.kt

import java.util.concurrent.TimeUnit.SECONDS
import okhttp3.MediaType
import okhttp3.RequestBody
import okio.BufferedSink
import org.junit.jupiter.api.Assertions.assertTrue

/** A duplex request body that keeps the provided sinks so they can be written to later.  */
class AsyncRequestBody : RequestBody() {
  private val requestBodySinks: BlockingQueue<BufferedSink> = LinkedBlockingQueue()

Registered: Fri Dec 26 11:42:13 UTC 2025

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

- 1.5K bytes

- Viewed (0)

github.com/square/okhttp

okhttp-coroutines/README.md

OkHttp Coroutines
=================

Support for Kotlin clients using coroutines.

```kotlin
val call = client.newCall(request)

call.executeAsync().use { response ->
  withContext(Dispatchers.IO) {
    println(response.body?.string())
  }
}
```

This is implemented using `suspendCancellableCoroutine`
but uses the standard Dispatcher in OkHttp. This means
that by default Kotlin's Dispatchers are not used.

Registered: Fri Dec 26 11:42:13 UTC 2025

- Last Modified: Thu Nov 09 15:47:27 UTC 2023

- 609 bytes

- Viewed (0)

github.com/square/okhttp

docs/features/caching.md

### Cache Hit

In the ideal scenario the cache can fulfill the request without any conditional call to the network.
This will skip the normal events such as DNS, connecting to the network, and downloading the response body.

As recommended by the HTTP RFC the max age of a document is defaulted to 10% of the 
document's age at the time it was served based on "Last-Modified". Default expiration dates aren't used for URIs 
containing a query.

Registered: Fri Dec 26 11:42:13 UTC 2025

- Last Modified: Sun Feb 06 02:19:09 UTC 2022

- 3.1K bytes

- Viewed (1)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/Exchange.kt

 */
class Exchange(
  internal val call: RealCall,
  internal val finder: ExchangeFinder,
  private val codec: ExchangeCodec,
) {
  /** True if the request body need not complete before the response body starts. */
  internal var isDuplex: Boolean = false
    private set

  /** True if there was an exception on the connection to the peer. */
  internal var hasFailure: Boolean = false
    private set

Registered: Fri Dec 26 11:42:13 UTC 2025

- Last Modified: Wed Nov 05 18:28:35 UTC 2025

- 10.5K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs/ru/docs/tutorial/handling-errors.md

```JSON hl_lines="12-15"
{
  "detail": [
    {
      "loc": [
        "body",
        "size"
      ],
      "msg": "value is not a valid integer",
      "type": "type_error.integer"
    }
  ],
  "body": {
    "title": "towel",
    "size": "XL"
  }
}
```

Registered: Sun Dec 28 07:19:09 UTC 2025

- Last Modified: Wed Dec 17 20:41:43 UTC 2025

- 14.1K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs_src/path_operation_advanced_configuration/tutorial007_pv1_py39.py

        "requestBody": {
            "content": {"application/x-yaml": {"schema": Item.schema()}},
            "required": True,
        },
    },
)
async def create_item(request: Request):
    raw_body = await request.body()
    try:
        data = yaml.safe_load(raw_body)
    except yaml.YAMLError:
        raise HTTPException(status_code=422, detail="Invalid YAML")
    try:
        item = Item.parse_obj(data)

Registered: Sun Dec 28 07:19:09 UTC 2025

- Last Modified: Sat Dec 20 15:55:38 UTC 2025

- 767 bytes

- Viewed (0)

Search Options