1 files changed, 28 insertions, 0 deletions
diff --git a/third_party/rust/warp/examples/sse.rs b/third_party/rust/warp/examples/sse.rs
new file mode 100644
index 0000000000..9c883a7c9a
--- /dev/null
+++ b/third_party/rust/warp/examples/sse.rs
@@ -0,0 +1,28 @@
+use futures::StreamExt;
+use std::convert::Infallible;
+use std::time::Duration;
+use tokio::time::interval;
+use warp::{sse::ServerSentEvent, Filter};
+
+// create server-sent event
+fn sse_counter(counter: u64) -> Result<impl ServerSentEvent, Infallible> {
+    Ok(warp::sse::data(counter))
+}
+
+#[tokio::main]
+async fn main() {
+    pretty_env_logger::init();
+
+    let routes = warp::path("ticks").and(warp::get()).map(|| {
+        let mut counter: u64 = 0;
+        // create server event source
+        let event_stream = interval(Duration::from_secs(1)).map(move |_| {
+            counter += 1;
+            sse_counter(counter)
+        });
+        // reply using server-sent events
+        warp::sse::reply(event_stream)
+    });
+
+    warp::serve(routes).run(([127, 0, 0, 1], 3030)).await;
+}