- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 627 for nwait (0.05 sec)
-
docs/de/docs/advanced/async-tests.md
Dann können wir einen `AsyncClient` mit der App erstellen und mit `await` asynchrone Requests an ihn senden. {* ../../docs_src/async_tests/test_main.py hl[9:12] *} Das ist das Äquivalent zu: ```Python response = client.get('/') ``` ... welches wir verwendet haben, um unsere Requests mit dem `TestClient` zu machen. /// tip | "Tipp" Beachten Sie, dass wir async/await mit dem neuen `AsyncClient` verwenden – der Request ist asynchron.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 27 15:34:47 UTC 2024 - 4.3K bytes - Viewed (0) -
docs/en/docs/advanced/async-tests.md
/// Then we can create an `AsyncClient` with the app, and send async requests to it, using `await`. {* ../../docs_src/async_tests/test_main.py hl[9:12] *} This is the equivalent to: ```Python response = client.get('/') ``` ...that we used to make our requests with the `TestClient`. /// tip Note that we're using async/await with the new `AsyncClient` - the request is asynchronous. /// /// warning
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 27 15:43:29 UTC 2024 - 3.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/MoreExecutors.java
* is complete. It does so by using daemon threads and adding a shutdown hook to wait for their * completion. * * <p>This is mainly for fixed thread pools. See {@link Executors#newFixedThreadPool(int)}. * * @param executor the executor to modify to make sure it exits when the application is finished * @param terminationTimeout how long to wait for the executor to finish before terminating the * JVM
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 44.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/TimeLimiter.java
* @param timeoutDuration with timeoutUnit, the maximum length of time that callers are willing to * wait on each method call to the proxy * @param timeoutUnit with timeoutDuration, the maximum length of time that callers are willing to * wait on each method call to the proxy * @return a time-limiting proxy * @throws IllegalArgumentException if {@code interfaceType} is a regular class, enum, or
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 15.3K bytes - Viewed (0) -
prepare_stmt.go
db.Mux.RUnlock() // wait for other goroutines prepared <-stmt.prepared if stmt.prepareErr != nil { return Stmt{}, stmt.prepareErr } return *stmt, nil } db.Mux.RUnlock() db.Mux.Lock() // double check if stmt, ok := db.Stmts[query]; ok && (!stmt.Transaction || isTransaction) { db.Mux.Unlock() // wait for other goroutines prepared <-stmt.prepared
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Aug 22 11:02:05 UTC 2024 - 6.6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/util/transport/Transport.java
te = null; thread = new Thread( this, name ); thread.setDaemon( true ); synchronized (thread) { thread.start(); thread.wait( timeout ); /* wait for doConnect */ switch (state) { case 1: /* doConnect never returned */ state = 0; thread = null;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 9K bytes - Viewed (0) -
docs_src/middleware/tutorial001.py
import time from fastapi import FastAPI, Request app = FastAPI() @app.middleware("http") async def add_process_time_header(request: Request, call_next): start_time = time.perf_counter() response = await call_next(request) process_time = time.perf_counter() - start_time response.headers["X-Process-Time"] = str(process_time)
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Aug 06 13:46:39 UTC 2024 - 365 bytes - Viewed (0) -
docs_src/async_tests/test_main.py
from .main import app @pytest.mark.anyio async def test_root(): async with AsyncClient( transport=ASGITransport(app=app), base_url="http://test" ) as ac: response = await ac.get("/") assert response.status_code == 200
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Fri Aug 30 16:00:41 UTC 2024 - 360 bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/DuplexTest.kt
override fun responseHeadersEnd( call: Call, response: Response, ) { try { // Wait for the server to send the duplex response before acting on the 301 response // and resetting the stream. duplexResponseSent.await() } catch (e: InterruptedException) { throw AssertionError() }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 23.9K bytes - Viewed (0) -
istioctl/pkg/util/testutil/util.go
if c.ExpectedOutput != "" && c.ExpectedOutput != output { t.Fatalf("Unexpected output for '%s %s'\n got: %q\nwant: %q", cmd.Name(), strings.Join(c.Args, " "), output, c.ExpectedOutput) } if c.ExpectedRegexp != nil && !c.ExpectedRegexp.MatchString(output) { t.Fatalf("Output didn't match for '%s %s'\n got %v\nwant: %v", cmd.Name(), strings.Join(c.Args, " "), output, c.ExpectedRegexp) } if c.GoldenFilename != "" {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 2K bytes - Viewed (0)