En particulier, cela peut être une bonne alternative à une logique dans un middleware.

Par exemple, si vous voulez lire ou manipuler le corps de la requête avant qu'il ne soit traité par votre application.

/// danger | Danger

Ceci est une fonctionnalité « avancée ».

Si vous débutez avec **FastAPI**, vous pouvez ignorer cette section.

///

通过使用 `with` 代码块，我们确保在生成器函数（带有 `yield` 的函数）完成后关闭这个类文件对象。也就是在发送完响应之后。

在这个特定示例中这并不那么重要，因为它是一个内存中的假文件（使用 `io.BytesIO`），但对于真实文件，确保在完成相关工作后关闭文件是很重要的。

### 文件与异步 { #files-and-async }

大多数情况下，类文件对象默认与 async 和 await 不兼容。

例如，它们没有 `await file.read()`，也不支持 `async for chunk in file`。

而且很多情况下，读取它们是一个阻塞操作（可能会阻塞事件循环），因为数据来自磁盘或网络。

/// info | 信息

上面的示例其实是个例外，因为 `io.BytesIO` 对象已经在内存中，所以读取它不会阻塞。

但在许多情况下，读取文件或类文件对象会发生阻塞。

///

            latch.countDown();
        }).error(error -> {
            errorRef.set(error);
            latch.countDown();
        });

        assertTrue("Should complete within timeout", latch.await(ASYNC_TIMEOUT_SECONDS, TimeUnit.SECONDS));
        assertNotNull("Should have response", responseRef.get());
        assertEquals(0, responseRef.get().getNumberOfInputDocs());
    }

    @Test

        .build()
    }
    val request =
      Request
        .Builder()
        .url(server.url("/"))
        .build()
    client.newCall(request).enqueue(callback)
    callback
      .await(request.url)
      .assertCode(200)
      .assertHeader("OkHttp-Intercepted", "yep")
  }

  @Test
  fun applicationInterceptorsCanMakeMultipleRequestsToServer() {

            })
        .start();

    // wait for the computingEntry to be created
    computationStarted.await();
    cache.invalidateAll();
    // let the computation proceed
    computingLatch.countDown();
    // don't check cache.size() until we know the get("b") call is complete
    computationComplete.await();

    // At this point, the listener should be holding the seed value (a -> a), and the map should

            })
        .start();

    // wait for the computingEntry to be created
    computationStarted.await();
    cache.invalidateAll();
    // let the computation proceed
    computingLatch.countDown();
    // don't check cache.size() until we know the get("b") call is complete
    computationComplete.await();

    // At this point, the listener should be holding the seed value (a -> a), and the map should

**FastAPI** напрямую предоставляет тот же самый `WebSocket` просто для удобства. На самом деле это `WebSocket` из Starlette.

///

## Ожидание и отправка сообщений { #await-for-messages-and-send-messages }

Через эндпоинт веб-сокета вы можете получать и отправлять сообщения.

{* ../../docs_src/websockets_/tutorial001_py310.py hl[48:52] *}

### Файли та async { #files-and-async }

У більшості випадків об'єкти, подібні до файлів, за замовчуванням несумісні з `async` та `await`.

Наприклад, у них немає `await file.read()` або `async for chunk in file`.

І часто їх читання є блокувальною операцією (що може блокувати цикл подій), адже дані зчитуються з диска або мережі.

/// info | Інформація

{* ../../docs_src/custom_response/tutorial007_py310.py hl[3,16] *}

/// note | 技術詳細

`async` タスクは `await` に到達したときにのみキャンセルできます。`await` がない場合、ジェネレータ（`yield` を持つ関数）は適切にキャンセルできず、キャンセル要求後も実行が続く可能性があります。

この小さな例では `await` が不要なため、イベントループにキャンセルを処理する機会を与えるために `await anyio.sleep(0)` を追加しています。

これは大きなストリームや無限ストリームではさらに重要になります。

///

/// tip | 豆知識

- `seek(offset)`: ファイル内のバイト位置 `offset`（`int`）に移動します。
    - 例: `await myfile.seek(0)` はファイルの先頭に移動します。
    - 一度 `await myfile.read()` を実行して、もう一度内容を読みたい場合に特に便利です。
- `close()`: ファイルを閉じます。

これらはすべて `async` メソッドなので、`await` する必要があります。

例えば、`async` の *path operation 関数* 内では次のように内容を取得できます:

```Python
contents = await myfile.read()
```

通常の `def` の *path operation 関数* 内にいる場合は、`UploadFile.file` に直接アクセスできます。例えば: