Function sml_message_stream 

pub fn sml_message_stream(
    stream: impl AsyncRead + Unpin + Send + 'static,
) -> impl Stream<Item = SmlMessages>

Read SML message stream from a reader

use std::io::Cursor;
use hackdose_sml_parser::message_stream::sml_message_stream;
use tokio_stream::StreamExt;

#[tokio::main]
async fn main() {
    let cursor = Cursor::new(vec![0x01, 0x02, 0x03]);
    let mut message_stream = sml_message_stream(cursor);
    while let Some(message) = message_stream.next().await {
        println!("Message: {:?}", message);
    }
}