pub async fn read_sync_msg<R: Stream<Item = Result<BytesMut>> + Unpin>(
read: &mut R,
) -> Result<Option<SyncMessage>, SyncRecvError>pub async fn read_sync_msg<R: Stream<Item = Result<BytesMut>> + Unpin>(
read: &mut R,
) -> Result<Option<SyncMessage>, SyncRecvError>