axum/examples/websockets/assets/index.html

<a>Open the console to see stuff, then refresh to initiate exchange.</a>
<script src='script.js'></script>
Updated websocket example to improve clarity and to be more distinct from chat example (#1637) Co-authored-by: David Pedersen <david.pdrsn@gmail.com> 2023-01-08 16:51:59 +01:00			`<a>Open the console to see stuff, then refresh to initiate exchange.</a>`
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>`