Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 231 - 240 of 444 for queues (0.04 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top