- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 603 for _wait (2.87 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.acceptFrame() // RST_STREAM peer.acceptFrame() // DEGRADED PING peer.acceptFrame() // AWAIT PING peer.sendFrame().ping(true, Http2Connection.DEGRADED_PING, 1) // DEGRADED PONG peer.sendFrame().ping(true, Http2Connection.AWAIT_PING, 0) // AWAIT PONG peer.play() // Play it back. val connection = connect(peer)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0) -
ci/devinfra/docker/windows/Dockerfile
'msys2.tar.xz'); \ Start-Process -FilePath \"C:\Program Files\7-Zip\7z.exe\" -ArgumentList 'x msys2.tar.xz -oC:\TEMP\msys2.tar' -Wait; \ Start-Process -FilePath \"C:\Program Files\7-Zip\7z.exe\" -ArgumentList 'x C:\TEMP\msys2.tar -oC:\tools' -Wait; \ $env:PATH = [Environment]::GetEnvironmentVariable('PATH', 'Machine') + ';C:\tools\msys64;C:\tools\msys64\usr\bin\'; \
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Tue Aug 20 13:57:04 UTC 2024 - 7.3K bytes - Viewed (0) -
cmd/erasure.go
w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout()) return w.Run(func() error { wait := deleteCleanupSleeper.Timer(ctx) removeAll(pathJoin(drivePath, minioMetaTmpDeletedBucket, ddir)) wait() return nil }) }) }(disk) } wg.Wait() } // nsScanner will start scanning buckets and send updated totals as they are traversed.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 22:23:33 UTC 2024 - 16.1K bytes - Viewed (0) -
docs_src/handling_errors/tutorial006.py
async def custom_http_exception_handler(request, exc): print(f"OMG! An HTTP error!: {repr(exc)}") return await http_exception_handler(request, exc) @app.exception_handler(RequestValidationError) async def validation_exception_handler(request, exc): print(f"OMG! The client sent invalid data!: {exc}") return await request_validation_exception_handler(request, exc) @app.get("/items/{item_id}")
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Aug 09 11:10:33 UTC 2020 - 928 bytes - Viewed (0) -
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) -
docs_src/generate_clients/tutorial004.js
import * as fs from 'fs' async function modifyOpenAPIFile(filePath) { try { const data = await fs.promises.readFile(filePath) const openapiContent = JSON.parse(data) const paths = openapiContent.paths for (const pathKey of Object.keys(paths)) { const pathData = paths[pathKey] for (const method of Object.keys(pathData)) { const operation = pathData[method] if (operation.tags && operation.tags.length > 0) {
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Thu Mar 14 11:40:05 UTC 2024 - 1K 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) -
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) -
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)