style(data): satisfy clippy + rustfmt on streaming download

Drop redundant .into() on already-Bytes decrypt result (clippy useless_conversion) and apply rustfmt reflows in file.rs + e2e_file.rs. No behavior change.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Author: Nic-dorman

ant-core/src/data/client/file.rs

@@ -2562,9 +2562,8 @@ impl Client {
         // a bounded sink can apply backpressure.
         let mut bytes_total = 0u64;
         for chunk_result in stream {
-            let chunk: Bytes = chunk_result
-                .map_err(|e| Error::Encryption(format!("decryption failed: {e}")))?
-                .into();
+            let chunk: Bytes =
+                chunk_result.map_err(|e| Error::Encryption(format!("decryption failed: {e}")))?;
             bytes_total += chunk.len() as u64;
             on_chunk(chunk).await?;
         }
@@ -2586,8 +2585,7 @@ impl Client {
 
         let parent = output.parent().unwrap_or_else(|| Path::new("."));
         let unique: u64 = rand::random();
-        let tmp_path =
-            parent.join(format!(".ant_download_{}_{unique}.tmp", std::process::id()));
+        let tmp_path = parent.join(format!(".ant_download_{}_{unique}.tmp", std::process::id()));
 
         let mut file = std::fs::File::create(&tmp_path)?;
         let write_result = self

ant-core/tests/e2e_file.rs

@@ -89,9 +89,7 @@ async fn test_file_download_to_sender_streaming() {
     // Channel item type is inferred from `file_download_to_sender`'s signature.
     let (tx, mut rx) = mpsc::channel(8);
     let data_map = result.data_map.clone();
-    let dl = tokio::spawn(async move {
-        client.file_download_to_sender(&data_map, tx, None).await
-    });
+    let dl = tokio::spawn(async move { client.file_download_to_sender(&data_map, tx, None).await });
 
     let mut streamed: Vec<u8> = Vec::with_capacity(data.len());
     while let Some(item) = rx.recv().await {