Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 507 for await (0.02 sec)

  1. docs/en/docs/advanced/custom-response.md

    /// tip
    
    Notice that here as we are using standard `open()` that doesn't support `async` and `await`, we declare the path operation with normal `def`.
    
    ///
    
    ### `FileResponse` { #fileresponse }
    
    Asynchronously streams a file as the response.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 12.2K bytes
    - Viewed (0)
  2. docs/yo/docs/index.md

    def read_item(item_id: int, q: Union[str, None] = None):
        return {"item_id": item_id, "q": q}
    ```
    
    <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"}
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 10:49:48 UTC 2025
    - 24.1K bytes
    - Viewed (0)
  3. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java

                    } else {
                        latch.countDown();
                    }
                }
                try {
                    latch.await();
                } catch (InterruptedException e) {
                    result.addErrorArtifactException(
                            new ArtifactResolutionException("Resolution interrupted", rootArtifact, e));
                }
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 25K bytes
    - Viewed (0)
  4. lib/wasm/wasm_exec.js

    				throw new Error("total length of command line and environment variables exceeds limit");
    			}
    
    			this._inst.exports.run(argc, argv);
    			if (this.exited) {
    				this._resolveExitPromise();
    			}
    			await this._exitPromise;
    		}
    
    		_resume() {
    			if (this.exited) {
    				throw new Error("Go program has already exited");
    			}
    			this._inst.exports.resume();
    			if (this.exited) {
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Sun Dec 08 15:34:47 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/util/WebApiUtilTest.java

                        errorCount.incrementAndGet();
                    } finally {
                        latch.countDown();
                    }
                }).start();
            }
    
            try {
                latch.await();
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
                fail("Thread safety test interrupted");
            }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 12 07:34:10 UTC 2025
    - 17.1K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/graph/AbstractNetworkTest.java

          futures.add(
              executor.submit(
                  new Callable<@Nullable Void>() {
                    @Override
                    public @Nullable Void call() throws Exception {
                      barrier.await();
                      Integer first = network.nodes().iterator().next();
                      for (Integer node : network.nodes()) {
                        Set<Integer> unused = network.successors(node);
                      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 32.7K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

        }
    
        // 0x4f 0x4b 0x6f 0x6b is "OKok".
        writePing(false, AWAIT_PING, 0x4f4b6f6b)
      }
    
      /** For testing: awaits a pong. */
      @Throws(InterruptedException::class)
      fun awaitPong() {
        withLock {
          while (awaitPongsReceived < awaitPingsSent) {
            wait()
          }
        }
      }
    
      @Throws(IOException::class)
      fun flush() {
        writer.flush()
      }
    
      /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 31.8K bytes
    - Viewed (0)
  8. docs/pt/docs/advanced/custom-response.md

    /// tip | Dica
    
    Perceba que aqui estamos utilizando o `open()` da biblioteca padrão que não suporta `async` e `await`, e declaramos a operação de rota com o `def` básico.
    
    ///
    
    ### `FileResponse`
    
    Envia um arquivo  de forma assíncrona e contínua (stream).
    *
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Nov 18 02:25:44 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

      }
    
      /** For testing: force this web socket to release its threads. */
      @Throws(InterruptedException::class)
      fun tearDown() {
        taskQueue.shutdown()
        taskQueue.idleLatch().await(10, TimeUnit.SECONDS)
      }
    
      @Synchronized fun sentPingCount(): Int = sentPingCount
    
      @Synchronized fun receivedPingCount(): Int = receivedPingCount
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/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 Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 24.8K bytes
    - Viewed (0)
Back to top