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>,
Expand description

handles all send msg and calls a handle fn Aborts when a error occurred returns cnt of successful msg otherwise