- Sort Score
- Num 10 results
- Language All
Results 231 - 240 of 444 for queues (0.04 seconds)
-
android/guava-tests/test/com/google/common/eventbus/AsyncEventBusTest.java
// Now we find the task in our Executor and explicitly activate it. List<Runnable> tasks = executor.getTasks(); assertEquals("One event dispatch task should be queued.", 1, tasks.size()); tasks.get(0).run(); assertEquals("One event should be delivered.", 1, events.size()); assertWithMessage("Correct string should be delivered.").that(events.get(0)).isEqualTo(EVENT); }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 2.4K bytes - Click Count (0) -
docs/es/docs/tutorial/dependencies/index.md
Como las dependencias también serán llamadas por **FastAPI** (lo mismo que tus *path operation functions*), las mismas reglas aplican al definir tus funciones. Puedes usar `async def` o `def` normal. Y puedes declarar dependencias con `async def` dentro de *path operation functions* normales `def`, o dependencias `def` dentro de *path operation functions* `async def`, etc. No importa. **FastAPI** sabrá qué hacer.
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:15:55 GMT 2026 - 10K bytes - Click Count (0) -
docs/es/docs/virtual-environments.md
Después de activar el entorno, puedes instalar paquetes en él. /// tip | Consejo Haz esto **una vez** al instalar o actualizar los paquetes que necesita tu proyecto. Si necesitas actualizar una versión o agregar un nuevo paquete, **harías esto de nuevo**. /// ### Instala Paquetes Directamente { #install-packages-directly }Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:15:55 GMT 2026 - 22.6K bytes - Click Count (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
// Cause acceptConnections() to break out. serverSocket.closeQuietly() // Await shutdown. for (queue in taskRunner.activeQueues()) { if (!queue.idleLatch().await(5, TimeUnit.SECONDS)) { throw AssertionError("Gave up waiting for queue to shut down") } } taskRunnerBackend.shutdown() } private fun serveConnection( connectionIndex: Int,Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 40.3K bytes - Click Count (0) -
docs/es/docs/tutorial/dependencies/global-dependencies.md
# Dependencias Globales { #global-dependencies } Para algunos tipos de aplicaciones, podrías querer agregar dependencias a toda la aplicación. Similar a como puedes [agregar `dependencies` a los *path operation decorators*](dependencies-in-path-operation-decorators.md), puedes agregarlos a la aplicación de `FastAPI`. En ese caso, se aplicarán a todas las *path operations* en la aplicación: {* ../../docs_src/dependencies/tutorial012_an_py310.py hl[17] *}Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:15:55 GMT 2026 - 1.1K bytes - Click Count (0) -
docs/es/docs/tutorial/testing.md
/// info | Información Ten en cuenta que el `TestClient` recibe datos que pueden ser convertidos a JSON, no modelos de Pydantic. Si tienes un modelo de Pydantic en tu prueba y quieres enviar sus datos a la aplicación durante las pruebas, puedes usar el `jsonable_encoder` descrito en [Codificador Compatible con JSON](encoder.md). /// ## Ejecútalo { #run-it } Después de eso, solo necesitas instalar `pytest`.
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:15:55 GMT 2026 - 6.1K bytes - Click Count (0) -
internal/event/target/kafka.go
return err } } if k.BatchSize > 1 { if k.QueueDir == "" { return errors.New("batch should be enabled only if queue dir is enabled") } } if k.BatchCommitTimeout > 0 { if k.QueueDir == "" || k.BatchSize <= 1 { return errors.New("batch commit timeout should be set only if queue dir is enabled and batch size > 1") } } return nil } // KafkaTarget - Kafka target.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 13.6K bytes - Click Count (0) -
docs/es/docs/how-to/authentication-error-status-code.md
Pero si por alguna razón tus clientes dependen del comportamiento anterior, puedes volver a él sobrescribiendo el método `make_not_authenticated_error` en tus clases de seguridad. Por ejemplo, puedes crear una subclase de `HTTPBearer` que devuelva un error `403 Forbidden` en lugar del `401 Unauthorized` por defecto:
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:15:55 GMT 2026 - 1.2K bytes - Click Count (0) -
docs/throttle/README.md
MinIO server allows to throttle incoming requests: - limit the number of active requests allowed across the cluster - limit the wait duration for each request in the queue These values are enabled using server's configuration or environment variables. ## Examples ### Configuring connection limit
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 16 08:43:49 GMT 2024 - 1.5K bytes - Click Count (1) -
docs/es/docs/advanced/openapi-webhooks.md
# Webhooks de OpenAPI { #openapi-webhooks } Hay casos donde quieres decirle a los **usuarios** de tu API que tu aplicación podría llamar a *su* aplicación (enviando una request) con algunos datos, normalmente para **notificar** de algún tipo de **evento**. Esto significa que en lugar del proceso normal de tus usuarios enviando requests a tu API, es **tu API** (o tu aplicación) la que podría **enviar requests a su sistema** (a su API, su aplicación).Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:15:55 GMT 2026 - 3.1K bytes - Click Count (0)