We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 77151c2 commit 96d4d8dCopy full SHA for 96d4d8d
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