Function send

tests/units/test_app.py:1129–1131

(message)

        return {"type": "http.disconnect"}

    async def send(message):  # noqa: RUF029
        if message.get("type") == "http.response.body" and not message.get("body"):
            done.set()

    await streaming_response(scope, receive, send)