|
1 | 1 | from __future__ import annotations |
2 | 2 |
|
3 | | -from typing import Any |
| 3 | +from collections.abc import AsyncIterable, Iterable |
| 4 | +from inspect import isasyncgen, isgenerator |
| 5 | +from typing import TYPE_CHECKING, Any |
4 | 6 |
|
5 | 7 | from quart import make_response as _make_response |
6 | 8 | from quart import request |
7 | 9 |
|
8 | 10 | from . import _read_signals |
9 | 11 | from .sse import SSE_HEADERS, ServerSentEventGenerator |
10 | 12 |
|
| 13 | +if TYPE_CHECKING: |
| 14 | + from quart.typing import HeadersValue, ResponseTypes, StatusCode |
| 15 | + |
11 | 16 | __all__ = [ |
12 | 17 | "SSE_HEADERS", |
13 | 18 | "ServerSentEventGenerator", |
|
16 | 21 | ] |
17 | 22 |
|
18 | 23 |
|
19 | | -async def make_datastar_response(async_generator): |
20 | | - response = await _make_response(async_generator, SSE_HEADERS) |
21 | | - response.timeout = None |
| 24 | +async def make_datastar_response( |
| 25 | + response_content: str | Iterable | AsyncIterable | None, |
| 26 | + status_or_headers: StatusCode | HeadersValue = None, |
| 27 | + headers: HeadersValue = None, |
| 28 | + /, |
| 29 | +) -> ResponseTypes: |
| 30 | + status = status_or_headers |
| 31 | + if status_or_headers is not None and not isinstance(status_or_headers, int): |
| 32 | + status, headers = None, status_or_headers |
| 33 | + headers = {**SSE_HEADERS, **(headers or {})} |
| 34 | + response = await _make_response(response_content, status, headers) |
| 35 | + if isgenerator(response_content) or isasyncgen(response_content): |
| 36 | + response.timeout = None |
22 | 37 | return response |
23 | 38 |
|
24 | 39 |
|
|
0 commit comments