Struct AsyncStreamProcessor 

pub struct AsyncStreamProcessor<R> { /* private fields */ }

Async stream processor for handling continuous message streams

Implementations

impl<R: AsyncRead + Unpin> AsyncStreamProcessor<R>

pub fn new(reader: R) -> Self

Create a new async stream processor

pub async fn next_message<T: for<'de> Deserialize<'de>>(&mut self) -> Result<T>

Process the next message from the stream

pub async fn process_all<T, F, Fut>(&mut self, handler: F) -> Result<()>

where T: for<'de> Deserialize<'de>, F: FnMut(T) -> Fut, Fut: Future<Output = Result<()>>,

Process all messages in the stream