chk
/
AppFlowy-Cloud
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'main' into hander_large_blob

This commit is contained in:
Fu Zi Xiang 2024-01-15 15:15:09 +08:00
parent d8c03055cd 5a353856af
commit 05c8080ec2
No known key found for this signature in database
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
libs/client-api/src/http.rs
View File

@ -806,6 +806,7 @@ impl Client {
.collect();
let mut framed_data = Vec::new();
let mut size_count = 0;
for task in compression_tasks {
let compressed = task.await??;
// The length of a u32 in bytes is 4. The server uses a u32 to read the size of each data frame,
@ -816,7 +817,13 @@ impl Client {
let size = compressed.len() as u32;
framed_data.extend_from_slice(&size.to_be_bytes());
framed_data.extend_from_slice(&compressed);
size_count += size;
}
event!(
tracing::Level::INFO,
"create batch collab with size: {}",
size_count
);
let body = Body::wrap_stream(stream::once(async { Ok::<_, AppError>(framed_data) }));
let resp = self
.http_client_with_auth_compress(Method::POST, &url)