let (tx, rx) = backup_client
  .upload_logs(&user_identity, &backup_data.backup_id)
  .await
  .unwrap();

tokio::pin!(tx);
tokio::pin!(rx);

for log_data in log_datas {
  tx.send(log_data.clone()).await.unwrap();
}

let result: HashSet<usize> =
  rx.take(log_datas.len()).try_collect().await.unwrap();
let expected = log_datas.iter().map(|data| data.log_id).collect();
assert_eq!(result, expected);