OpenSource/axum - Moe's Git

OpenSource/axum

mirror of https://github.com/tokio-rs/axum.git synced 2024-11-26 00:56:27 +01:00

2 lines

34 B

HTML

Raw Normal View History

Server-Sent Events (#75) Example usage: ```rust use axum::{prelude::*, sse::{sse, Event, KeepAlive}}; use tokio_stream::StreamExt as _; use futures::stream::{self, Stream}; use std::{ time::Duration, convert::Infallible, }; let app = route("/sse", sse(make_stream).keep_alive(KeepAlive::default())); async fn make_stream( // you can also put extractors here ) -> Result<impl Stream<Item = Result<Event, Infallible>>, Infallible> { // A `Stream` that repeats an event every second let stream = stream::repeat_with(|| Event::default().data("hi!")) .map(Ok) .throttle(Duration::from_secs(1)); Ok(stream) } ``` Implementation is based on [warp's](https://github.com/seanmonstar/warp/blob/master/src/filters/sse.rs)

2021-08-01 21:49:17 +02:00

<script src='script.js'></script>