We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents b2d59ca + 96d4d8d commit 0916848Copy full SHA for 0916848
libsql-wal/src/storage/backend/s3.rs
@@ -310,7 +310,9 @@ impl<IO: Io> S3Backend<IO> {
310
let mut current_chunk_len = 0;
311
tokio::pin!(data);
312
loop {
313
- let Some(frame) = poll_fn(|cx| data.as_mut().poll_frame(cx)).await else {
+ let next_frame_fut = poll_fn(|cx| data.as_mut().poll_frame(cx));
314
+ let Some(frame) = next_frame_fut.await else {
315
+ let _ = s_chunks.send(current_chunk_file).await;
316
break;
317
};
318
let frame = frame?;
0 commit comments