Function create_message_stream 

pub fn create_message_stream(
    text: &str,
) -> Pin<Box<dyn Stream<Item = Result<Message, SseCodecError>> + Send + Sync>>

Creates a stream of Message instances from a text stream of SSE events.