From 77113964cf1d810d2f9c3684ab57edb9c53e73a8 Mon Sep 17 00:00:00 2001
From: fufesou <linlong1266@gmail.com>
Date: Fri, 28 Mar 2025 17:26:41 +0800
Subject: [PATCH] fix: fs, flush before getting the buf

Signed-off-by: fufesou <linlong1266@gmail.com>
---
 src/fs.rs | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/src/fs.rs b/src/fs.rs
index d30e7bf..4401a97 100644
--- a/src/fs.rs
+++ b/src/fs.rs
@@ -513,10 +513,13 @@ impl TransferJob {
         })
     }
 
-    pub fn get_buf_data(self) -> Option<Vec<u8>> {
+    pub async fn get_buf_data(self) -> ResultType<Option<Vec<u8>>> {
         match self.data_stream {
-            Some(DataStream::BufStream(bs)) => Some(bs.into_inner().into_inner()),
-            _ => None,
+            Some(DataStream::BufStream(mut bs)) => {
+                bs.flush().await?;
+                Ok(Some(bs.into_inner().into_inner()))
+            }
+            _ => Ok(None),
         }
     }