override fun onResponse(
          call: Call,
          response: Response,
        ) {
          response.close()
          latch.countDown()
        }
      },
    )
    latch.await()
    assertThat(call.isCanceled()).isTrue()
    assertThat(exceptionRef.get()).isNotNull()
  }

  @Test
  fun timeoutProcessing() {
    server.enqueue(
      MockResponse
        .Builder()

/// note | 技術細節

你也可以使用 `from starlette.websockets import WebSocket`。

**FastAPI** 直接提供相同的 `WebSocket` 只是為了方便你這位開發者，但它其實是直接來自 Starlette。

///

## 等待與傳送訊息 { #await-for-messages-and-send-messages }

在你的 WebSocket 路由中，你可以 `await` 接收訊息並傳送訊息。

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

你可以接收與傳送二進位、文字與 JSON 資料。

## 試試看 { #try-it }

如果你的檔案名為 `main.py`，用以下指令執行應用：

```Python
with open("file.txt") as file:
    file.read()
```

En versiones recientes de Python, también hay un **async context manager**. Lo usarías con `async with`:

```Python
async with lifespan(app):
    await do_stuff()
```

import pytest

from docs_src.async_tests.app_a_py310.test_main import test_root


@pytest.mark.anyio
async def test_async_testing():

            AtomicInteger completedOps = new AtomicInteger(0);

            for (int t = 0; t < threadCount; t++) {
                executor.submit(() -> {
                    try {
                        startLatch.await(); // All threads start simultaneously
                        for (int i = 0; i < operationsPerThread; i++) {
                            byte[] localData = new byte[128];

///

## Attendre des messages et envoyer des messages { #await-for-messages-and-send-messages }

Dans votre route WebSocket, vous pouvez `await` des messages et envoyer des messages.

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

Vous pouvez recevoir et envoyer des données binaires, texte et JSON.

{* ../../docs_src/async_tests/app_a_py310/test_main.py hl[9:12] *}

Это эквивалентно следующему:

```Python
response = client.get('/')
```

...которое мы использовали для отправки наших запросов с `TestClient`.

/// tip | Подсказка

Обратите внимание, что мы используем async/await с `AsyncClient` - запрос асинхронный.

///

        self.context_name = context_name

    async def __call__(self, scope: Scope, receive: Receive, send: Send) -> None:
        async with AsyncExitStack() as stack:
            scope[self.context_name] = stack

			}

			now := time.Now()
			if now.Sub(u.Queued) < time.Second {
				// let recently failed networks to reconnect
				// making MRF wait for 1s before retrying,
				// i.e 4 reconnect attempts.
				time.Sleep(time.Second)
			}

			// wait on timer per heal
			wait := healSleeper.Timer(context.Background())

			scan := madmin.HealNormalScan
			if u.BitrotScan {
				scan = madmin.HealDeepScan
			}

            executorService.submit(
                () -> {
                  startLatch.countDown();
                  startLatch.await();
                  callable.call();
                  doneLatch.countDown();
                  return null;
                });
      }
      doneLatch.await();
    } finally {
      executorService.shutdown();
    }
  }