pub(crate) fn try_recv_all<M, F>( client: &mut Client, stream_id: u8, f: F, ) -> Result<u64, Error>where M: DeserializeOwned, F: FnMut(&Client, M) -> Result<(), Error>,
handles all send msg and calls a handle fn Aborts when a error occurred returns cnt of successful msg otherwise