From - Code Search

okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

  /**
   * If true, no new exchanges can be created on this connection. It is necessary to set this to
   * true when removing a connection from the pool; otherwise a racing caller might get it from the
   * pool when it shouldn't. Symmetrically, this must always be checked before returning a
   * connection from the pool.
   *
   * Once true this is always true. Guarded by this.
   */
  var noNewExchanges = false

  /**

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Sat Apr 20 17:03:43 UTC 2024

- 15.4K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs/en/docs/advanced/behind-a-proxy.md

<a href="https://github.com/containous/traefik/releases" class="external-link" target="_blank">Download Traefik</a>, it's a single binary, you can extract the compressed file and run it directly from the terminal.

Then create a file `traefik.toml` with:

```TOML hl_lines="3"
[entryPoints]
  [entryPoints.http]
    address = ":9999"

[providers]
  [providers.file]

Registered: Sun Nov 03 07:19:11 UTC 2024

- Last Modified: Sun Oct 27 16:49:49 UTC 2024

- 11.6K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

ci/official/utilities/setup_docker.sh

  docker pull "$TFCI_DOCKER_IMAGE" || sleep 60
  docker pull "$TFCI_DOCKER_IMAGE"
fi 

if [[ "$TFCI_DOCKER_REBUILD_ENABLE" == 1 ]]; then
  DOCKER_BUILDKIT=1 docker build --cache-from "$TFCI_DOCKER_IMAGE" -t "$TFCI_DOCKER_IMAGE" $TFCI_DOCKER_REBUILD_ARGS
  if [[ "$TFCI_DOCKER_REBUILD_UPLOAD_ENABLE" == 1 ]]; then
    docker push "$TFCI_DOCKER_IMAGE"
  fi
fi

Registered: Tue Nov 05 12:39:12 UTC 2024

- Last Modified: Fri Aug 09 16:05:18 UTC 2024

- 2.8K bytes

- Viewed (0)

github.com/istio/istio

licenses/gopkg.in/yaml.v3/LICENSE

This project is covered by two different licenses: MIT and Apache.

#### MIT License ####

The following files were ported to Go from C files of libyaml, and thus
are still covered by their original MIT license, with the additional
copyright staring in 2011 when the project was ported over:

    apic.go emitterc.go parserc.go readerc.go scannerc.go
    writerc.go yamlh.go yamlprivateh.go

Copyright (c) 2006-2010 Kirill Simonov

Registered: Wed Nov 06 22:53:10 UTC 2024

- Last Modified: Fri Feb 28 19:48:10 UTC 2020

- 2.1K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs/em/docs/advanced/response-headers.md

```Python hl_lines="10-12"
{!../../docs_src/response_headers/tutorial001.py!}
```

/// note | "📡 ℹ"

👆 💪 ⚙️ `from starlette.responses import Response` ⚖️ `from starlette.responses import JSONResponse`.

**FastAPI** 🚚 🎏 `starlette.responses` `fastapi.responses` 🏪 👆, 👩‍💻. ✋️ 🌅 💪 📨 👟 🔗 ⚪️➡️ 💃.

Registered: Sun Nov 03 07:19:11 UTC 2024

- Last Modified: Sun Oct 06 20:36:54 UTC 2024

- 1.8K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs_src/websockets/tutorial002_py310.py

from fastapi import (
    Cookie,
    Depends,
    FastAPI,
    Query,
    WebSocket,
    WebSocketException,
    status,
)
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)">

Registered: Sun Nov 03 07:19:11 UTC 2024

- Last Modified: Sat Mar 18 12:29:59 UTC 2023

- 2.7K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

    addListener(
        new Listener() {
          @Override
          public void terminated(State from) {
            executor.shutdown();
          }

          @Override
          public void failed(State from, Throwable failure) {
            executor.shutdown();
          }
        },
        directExecutor());
    return executor;
  }

  /**

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Fri Oct 25 16:22:21 UTC 2024

- 27.8K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/util/concurrent/RateLimiter.java

 * {@link #acquire()} blocks if necessary until a permit is available, and then takes it. Once
 * acquired, permits need not be released.
 *
 * <p>{@code RateLimiter} is safe for concurrent use: It will restrict the total rate of calls from
 * all threads. Note, however, that it does not guarantee fairness.
 *
 * <p>Rate limiters are often used to restrict the rate at which some physical or logical resource

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Sat Oct 19 00:51:36 UTC 2024

- 21.6K bytes

- Viewed (0)

github.com/minio/minio

internal/s3select/sql/value.go

	}
}

// FromFloat creates a Value from a number
func FromFloat(f float64) *Value {
	return &Value{value: f}
}

// FromInt creates a Value from an int
func FromInt(f int64) *Value {
	return &Value{value: f}
}

// FromString creates a Value from a string
func FromString(str string) *Value {
	return &Value{value: str}
}

// FromBool creates a Value from a bool
func FromBool(b bool) *Value {

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Fri Feb 25 20:31:19 UTC 2022

- 20.2K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/pac/ASN1Util.java

     * @return next element from enumeration cast to type
     * @throws PACDecodingException
     */
    public static <T extends Object> T as ( Class<T> type, Enumeration<?> enumeration ) throws PACDecodingException {
        return as(type, enumeration.nextElement());
    }


    /**
     * 
     * @param type
     * @param stream
     * @return next object from stream cast to type

Registered: Sun Nov 03 00:10:13 UTC 2024

- Last Modified: Mon Oct 02 12:02:06 UTC 2023

- 6.5K bytes

- Viewed (0)

Search Options