Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 627 for nwait (0.04 sec)

  1. docs/pt/docs/async.md

    # Concorrência e async / await
    
    Detalhes sobre a sintaxe `async def` para *funções de operação de rota* e alguns conceitos de código assíncrono, concorrência e paralelismo.
    
    ## Com pressa?
    
    <abbr title="muito longo; não li"><strong>TL;DR:</strong></abbr>
    
    Se você estiver utilizando bibliotecas de terceiros que dizem para você chamar as funções com `await`, como:
    
    ```Python
    results = await some_library()
    ```
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  2. tests/test_http_connection_injection.py

        return value
    
    
    @app.websocket("/ws")
    async def get_value_by_ws(
        websocket: WebSocket, value: int = Depends(extract_value_from_http_connection)
    ):
        await websocket.accept()
        await websocket.send_json(value)
        await websocket.close()
    
    
    client = TestClient(app)
    
    
    def test_value_extracting_by_http():
        response = client.get("/http")
        assert response.status_code == 200
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Aug 09 13:56:41 UTC 2020
    - 972 bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

              fail("")
            }
          },
        )
        assertThat(server.takeRequest().sequenceNumber)
          .isEqualTo(expectedSequenceNumber)
        responseDequeuedLatch!!.await()
        call.cancel()
        requestCanceledLatch!!.countDown()
        latch.await()
      }
    
      @ParameterizedTest
      @ArgumentsSource(ProtocolParamProvider::class)
      fun noRecoveryFromRefusedStreamWithRetryDisabled(
        protocol: Protocol,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 75.3K bytes
    - Viewed (0)
  4. docs/em/docs/async.md

    🚥 👆 ⚙️ 🥉 🥳 🗃 👈 💬 👆 🤙 👫 ⏮️ `await`, 💖:
    
    ```Python
    results = await some_library()
    ```
    
    ⤴️, 📣 👆 *➡ 🛠️ 🔢* ⏮️ `async def` 💖:
    
    ```Python hl_lines="2"
    @app.get('/')
    async def read_results():
        results = await some_library()
        return results
    ```
    
    /// note
    
    👆 💪 🕴 ⚙️ `await` 🔘 🔢 ✍ ⏮️ `async def`.
    
    ///
    
    ---
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  5. internal/ioutil/wait_pipe.go

    	})
    	return err
    }
    
    // PipeReader is similar to io.PipeReader with wait group
    type PipeReader struct {
    	*io.PipeReader
    	wait func()
    }
    
    // CloseWithError close with supplied error the reader end
    func (r *PipeReader) CloseWithError(err error) error {
    	err = r.PipeReader.CloseWithError(err)
    	r.wait()
    	return err
    }
    
    // WaitPipe implements wait-group backend io.Pipe to provide
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 27 14:55:36 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  6. docs/de/docs/async.md

    # Nebenläufigkeit und async / await
    
    Details zur `async def`-Syntax für *Pfadoperation-Funktionen* und Hintergrundinformationen zu asynchronem Code, Nebenläufigkeit und Parallelität.
    
    ## In Eile?
    
    <abbr title="too long; didn't read – Zu lang; nicht gelesen"><strong>TL;DR:</strong></abbr>
    
    Wenn Sie Bibliotheken von Dritten verwenden, die mit `await` aufgerufen werden müssen, wie zum Beispiel:
    
    ```Python
    results = await some_library()
    ```
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/AutobahnTester.kt

              t: Throwable,
              response: Response?,
            ) {
              t.printStackTrace(System.out)
              latch.countDown()
            }
          },
        )
    
        check(latch.await(30, TimeUnit.SECONDS)) { "Timed out waiting for test $number to finish." }
        val endNanos = System.nanoTime()
        val tookMs = TimeUnit.NANOSECONDS.toMillis(endNanos - startNanos.get())
        println("Took ${tookMs}ms")
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  8. docs_src/websockets/tutorial001.py

    </html>
    """
    
    
    @app.get("/")
    async def get():
        return HTMLResponse(html)
    
    
    @app.websocket("/ws")
    async def websocket_endpoint(websocket: WebSocket):
        await websocket.accept()
        while True:
            data = await websocket.receive_text()
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Mar 26 19:09:53 UTC 2020
    - 1.4K bytes
    - Viewed (0)
  9. fastapi/concurrency.py

        exit_limiter = CapacityLimiter(1)
        try:
            yield await run_in_threadpool(cm.__enter__)
        except Exception as e:
            ok = bool(
                await anyio.to_thread.run_sync(
                    cm.__exit__, type(e), e, None, limiter=exit_limiter
                )
            )
            if not ok:
                raise e
        else:
            await anyio.to_thread.run_sync(
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Dec 25 17:57:35 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

        }
      }
    
      /**
       * Like [Object.wait], but throws an [InterruptedIOException] when interrupted instead of the more
       * awkward [InterruptedException].
       */
      @Throws(InterruptedIOException::class)
      internal fun waitForIo() {
        try {
          condition.await()
        } catch (_: InterruptedException) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 23.2K bytes
    - Viewed (0)
Back to top