Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 51 - 60 of 799 for asyncId (0.29 seconds)

  1. tests/benchmarks/test_general_performance.py

    
    @app.get("/async/large-dict-no-response-model")
    async def async_large_dict_no_response_model():
        return LARGE_PAYLOAD
    
    
    @app.get("/async/large-dict-with-response-model", response_model=LargeOut)
    async def async_large_dict_with_response_model():
        return LARGE_PAYLOAD
    
    
    @app.get("/async/large-model-no-response-model")
    async def async_large_model_no_response_model():
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Dec 26 20:40:26 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java

      public void testCancel_beforeSet() throws Exception {
        SettableFuture<Object> async = SettableFuture.create();
        async.cancel(true);
        assertFalse(async.set(42));
      }
    
      public void testCancel_multipleBeforeSetFuture_noInterruptFirst() throws Exception {
        SettableFuture<Object> async = SettableFuture.create();
        async.cancel(false);
        async.cancel(true);
        SettableFuture<Object> inner = SettableFuture.create();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.4K bytes
    - Click Count (0)
  3. tests/test_dependency_partial.py

        return value
    
    
    @app.get("/partial-async-callable-dependency")
    async def get_partial_async_callable_dependency(
        value: Annotated[
            str,
            Depends(
                partial(async_callable_dependency, "partial-async-callable-dependency")
            ),
        ],
    ) -> str:
        return value
    
    
    @app.get("/partial-async-callable-gen-dependency")
    async def get_partial_async_callable_gen_dependency(
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Wed Dec 17 21:25:59 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  4. tests/test_stream_cancellation.py

    @app.get("/stream-raw", response_class=StreamingResponse)
    async def stream_raw() -> AsyncIterable[str]:
        """Async generator with no internal await - would hang without checkpoint."""
        i = 0
        while True:
            yield f"item {i}\n"
            i += 1
    
    
    @app.get("/stream-jsonl")
    async def stream_jsonl() -> AsyncIterable[int]:
        """JSONL async generator with no internal await."""
        i = 0
        while True:
            yield i
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Feb 27 18:56:47 GMT 2026
    - 2.7K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java

      public void testCancel_beforeSet() throws Exception {
        SettableFuture<Object> async = SettableFuture.create();
        async.cancel(true);
        assertFalse(async.set(42));
      }
    
      public void testCancel_multipleBeforeSetFuture_noInterruptFirst() throws Exception {
        SettableFuture<Object> async = SettableFuture.create();
        async.cancel(false);
        async.cancel(true);
        SettableFuture<Object> inner = SettableFuture.create();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.4K bytes
    - Click Count (0)
  6. tests/test_dependency_contextmanager.py

        pass
    
    
    class SyncDependencyError(Exception):
        pass
    
    
    class OtherDependencyError(Exception):
        pass
    
    
    async def asyncgen_state(state: dict[str, str] = Depends(get_state)):
        state["/async"] = "asyncgen started"
        yield state["/async"]
        state["/async"] = "asyncgen completed"
    
    
    def generator_state(state: dict[str, str] = Depends(get_state)):
        state["/sync"] = "generator started"
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Wed Dec 17 21:25:59 GMT 2025
    - 11.5K bytes
    - Click Count (0)
  7. tensorflow/c/eager/c_api_remote_function_test.cc

    namespace {
    
    void TestRemoteExecuteSilentCopiesFunc(bool async, bool remote,
                                           bool heavy_load_on_streaming_rpc,
                                           bool remote_func_outputs = false,
                                           bool has_packed_input = false) {
      return TestRemoteExecuteSilentCopies(async, remote, /*func=*/true,
                                           heavy_load_on_streaming_rpc,
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Fri Dec 11 22:56:03 GMT 2020
    - 3.6K bytes
    - Click Count (0)
  8. tests/test_ambiguous_params.py

            @app.get("/items/{item_id}/")
            async def get_item(item_id: Annotated[int, Path(default=1)]):
                pass  # pragma: nocover
    
        with pytest.raises(
            AssertionError,
            match=(
                "`Query` default value cannot be set in `Annotated` for 'item_id'. Set the"
                " default value with `=` instead."
            ),
        ):
    
            @app.get("/")
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sat Dec 20 15:55:38 GMT 2025
    - 2K bytes
    - Click Count (1)
  9. tests/test_multipart_installation.py

            monkeypatch.delattr("multipart.multipart.parse_options_header", raising=False)
        with pytest.raises(RuntimeError, match=multipart_incorrect_install_error):
            app = FastAPI()
    
            @app.post("/")
            async def root(username: str = Form()):
                return username  # pragma: nocover
    
    
    def test_incorrect_multipart_installed_file_upload(monkeypatch):
        monkeypatch.setattr("python_multipart.__version__", "0.0.12")
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Oct 27 21:46:26 GMT 2024
    - 5.7K bytes
    - Click Count (0)
  10. fastapi/datastructures.py

    
        @app.post("/files/")
        async def create_file(file: Annotated[bytes, File()]):
            return {"file_size": len(file)}
    
    
        @app.post("/uploadfile/")
        async def create_upload_file(file: UploadFile):
            return {"filename": file.filename}
        ```
        """
    
        file: Annotated[
            BinaryIO,
            Doc("The standard Python file object (non-async)."),
        ]
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Mar 15 11:44:39 GMT 2026
    - 5.2K bytes
    - Click Count (0)
Back to Top