use futures::SinkExt;
use sse_codec::{encode_stream, Event};
async fn amain() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
let output = async_std::io::stdout();
let mut stream = encode_stream(output);
stream.send(Event::message("message", "test", None)).await?;
stream
.send(Event::message(
"something-else",
"some-data\non\nmultiple-lines",
None,
))
.await?;
Ok(())
}
fn main() {
async_std::task::block_on(async {
amain().await.unwrap();
});
}