tokio-rs/axum
1
0
Fork 0
mirror of https://github.com/tokio-rs/axum.git synced 2026-08-27 00:00:24 +02:00
Code Issues Packages Projects Releases Wiki Activity

Mention tokio-stream in SSE example

Browse Source
This commit is contained in:
David Pedersen
2023-08-06 20:45:35 +02:00
parent cc611b8b24
commit e8cf5f4f0e
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
examples/sse/src/main.rs
+3
View File
@@ -50,6 +50,9 @@ async fn sse_handler(
println!("`{}` connected", user_agent.as_str()); println!("`{}` connected", user_agent.as_str());
// A `Stream` that repeats an event every second // A `Stream` that repeats an event every second
//
// You can also create streams from tokio channels using the wrappers in
// https://docs.rs/tokio-stream
let stream = stream::repeat_with(|| Event::default().data("hi!")) let stream = stream::repeat_with(|| Event::default().data("hi!"))
.map(Ok) .map(Ok)
.throttle(Duration::from_secs(1)); .throttle(Duration::from_secs(1));