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