Skip to content

Commit bb24bc4

Browse files
committed
formatting
1 parent a5fb272 commit bb24bc4

2 files changed

Lines changed: 8 additions & 14 deletions

File tree

04_sse/sse_chatbot.py

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -104,14 +104,10 @@ def send_message(msg: str):
104104
assistant_msg = Div(
105105
ChatMessage(
106106
len(messages) - 1,
107-
hx_ext="sse",
108-
sse_connect="/get-message",
109-
sse_swap="message",
110-
sse_close="close",
111-
hx_swap="beforeend",
112-
)
107+
hx_ext="sse", sse_connect="/get-message", sse_swap="message", sse_close="close",
108+
hx_swap="beforeend")
113109
)
114110
return user_msg, assistant_msg, ChatInput()
115111

116-
117112
serve()
113+

04_sse/sse_clock_scroll.py

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -10,21 +10,19 @@ def index():
1010
return Titled("SSE Clock",
1111
P("Display each second. As the display grows scroll downwards."),
1212
Div(hx_ext="sse", sse_connect="/time-sender",
13-
hx_swap="beforeend show:bottom",
14-
sse_swap="message")
13+
hx_swap="beforeend show:bottom", sse_swap="message")
1514
)
1615

17-
shutdown_event = signal_shutdown()
16+
event = signal_shutdown()
1817
async def time_generator():
19-
while not shutdown_event.is_set():
20-
data = Article(datetime.now().strftime('%H:%M:%S'))
21-
yield sse_message(data)
18+
while not event.is_set():
19+
yield sse_message(Article(datetime.now().strftime('%H:%M:%S')))
2220
await sleep(1)
2321

2422
@rt("/time-sender")
2523
async def get():
2624
"Send time to all connected clients every second"
2725
return EventStream(time_generator())
2826

29-
3027
serve()
28+

0 commit comments

Comments
 (0)