async_sse
pub fn decode<R>(reader: R) -> Decoder<R> where R: AsyncBufRead + Unpin,
Decode a new incoming SSE connection.