- Sort Score
- Result 10 results
- Languages All
Results 841 - 850 of 1,181 for rsync (0.05 sec)
-
internal/logger/target/http/http.go
workers atomic.Int64 maxWorkers int64 // workerStartMu sync.Mutex lastStarted time.Time wg sync.WaitGroup // Channel of log entries. // Reading logCh must hold read lock on logChMu (to avoid read race) // Sending a value on logCh must hold read lock on logChMu (to avoid closing) logCh chan interface{} logChMu sync.RWMutex // If this webhook is being re-configured we will
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 11 22:20:42 UTC 2024 - 15.6K bytes - Viewed (0) -
docs/nl/docs/index.md
<summary>Of maak gebruik van <code>async def</code>...</summary> Als je code gebruik maakt van `async` / `await`, gebruik dan `async def`: ```Python hl_lines="9 14" from typing import Union from fastapi import FastAPI app = FastAPI() @app.get("/") async def read_root(): return {"Hello": "World"} @app.get("/items/{item_id}")
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 20 19:20:23 UTC 2024 - 21.2K bytes - Viewed (0) -
cmd/post-policy-fan-out.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "bytes" "context" "sync" "github.com/minio/minio-go/v7" "github.com/minio/minio-go/v7/pkg/s3utils" "github.com/minio/minio/internal/crypto" "github.com/minio/minio/internal/hash" xhttp "github.com/minio/minio/internal/http"
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 3.5K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn_test.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package deadlineconn import ( "bufio" "io" "net" "sync" "testing" "time" ) // Test deadlineconn handles read timeout properly by reading two messages beyond deadline. func TestBuffConnReadTimeout(t *testing.T) { l, err := net.Listen("tcp", "localhost:0")
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Nov 05 18:09:21 UTC 2022 - 3K bytes - Viewed (0) -
docs/de/docs/tutorial/dependencies/sub-dependencies.md
//// tab | Python 3.8+ ```Python hl_lines="1" async def needy_dependency(fresh_value: Annotated[str, Depends(get_value, use_cache=False)]): return {"fresh_value": fresh_value} ``` //// //// tab | Python 3.8+ nicht annotiert /// tip | "Tipp" Bevorzugen Sie die `Annotated`-Version, falls möglich. /// ```Python hl_lines="1"
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 6.2K bytes - Viewed (0) -
docs/yo/docs/index.md
<details markdown="1"> <summary>Tàbí lò <code>async def</code>...</summary> Tí kóòdù rẹ̀ bá ń lò `async` / `await`, lò `async def`: ```Python hl_lines="9 14" from typing import Union from fastapi import FastAPI app = FastAPI() @app.get("/") async def read_root(): return {"Hello": "World"} @app.get("/items/{item_id}") async def read_item(item_id: int, q: Union[str, None] = None):
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 20 19:20:23 UTC 2024 - 24.1K bytes - Viewed (0) -
docs_src/path_operation_configuration/tutorial004_py310.py
class Item(BaseModel): name: str description: str | None = None price: float tax: float | None = None tags: set[str] = set() @app.post("/items/", response_model=Item, summary="Create an item") async def create_item(item: Item): """ Create an item with all the information: - **name**: each item must have a name - **description**: a long description - **price**: required
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Fri Jan 07 14:11:31 UTC 2022 - 638 bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/escape/super/com/google/common/escape/Platform.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 1.1K bytes - Viewed (0) -
src/main/java/jcifs/internal/CommonServerMessageBlockResponse.java
import jcifs.util.transport.Response; /** * @author mbechler * */ public interface CommonServerMessageBlockResponse extends CommonServerMessageBlock, Response { /** * * @return is an async response */ boolean isAsync (); /** * * @return the next response */ @Override CommonServerMessageBlockResponse getNextResponse (); /**
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 1.3K bytes - Viewed (0) -
tests/test_security_oauth2_authorization_code_bearer.py
from fastapi.testclient import TestClient app = FastAPI() oauth2_scheme = OAuth2AuthorizationCodeBearer( authorizationUrl="authorize", tokenUrl="token", auto_error=True ) @app.get("/items/") async def read_items(token: Optional[str] = Security(oauth2_scheme)): return {"token": token} client = TestClient(app) def test_no_token(): response = client.get("/items")
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Fri Jun 30 18:25:16 UTC 2023 - 2.3K bytes - Viewed (0)