starlette example

examples/starlette_app.py

@@ -0,0 +1,39 @@
+import asyncio
+from collections.abc import AsyncIterator
+
+from starlette.applications import Starlette
+from starlette.requests import Request
+from starlette.responses import HTMLResponse, StreamingResponse
+
+import htpy as h
+
+app = Starlette(debug=True)
+
+
+@app.route("/")
+async def homepage(request: Request) -> HTMLResponse:
+ return HTMLResponse(
+ h.div[
+ h.h1["Hello, World!"],
+ h.p["This is a simple example of using htpy with Starlette."],
+ h.a(href=str(request.url_for("stream")))["Go to the async stream example"],
+ ],
+ )
+
+
+async def slow_numbers(minimum: int, maximum: int) -> AsyncIterator[int]:
+ for number in range(minimum, maximum + 1):
+ yield number
+ await asyncio.sleep(0.5)
+
+
+@app.route("/stream", name="stream")
+async def async_stream(request: Request) -> StreamingResponse:
+ return StreamingResponse(
+ h.div[
+ h.h1["Async Stream"],
+ h.p["This page is generated asyncronously."],
+ h.ul[(h.li[str(num)] async for num in slow_numbers(1, 10))],
+ ],
+ media_type="text/html",
+ )

htpy/__init__.py

@@ -139,11 +139,16 @@ def iter_node(x: Node) -> Iterator[str]:
 
 
 async def aiter_node(x: Node) -> AsyncIterator[str]:
- while isinstance(x, Awaitable) or (not isinstance(x, BaseElement) and callable(x)):
+ while True:
  if isinstance(x, Awaitable):
  x = await x
- else:
+ continue
+
+ if not isinstance(x, BaseElement) and callable(x):
  x = x()
+ continue
+
+ break
 
  if x is None:
  return