We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0a32923 commit ad95949Copy full SHA for ad95949
1 file changed
libsql-server/src/bottomless_migrate.rs
@@ -58,14 +58,14 @@ pub async fn bottomless_migrate(
58
59
let (sender, mut rcv) = tokio::sync::mpsc::channel(1);
60
61
+ // we are not checkpointing anything, be we want to drain the receiver
62
tokio::spawn(async move {
63
loop {
64
match rcv.recv().await {
- Some(libsql_wal::checkpointer::CheckpointMessage::Shutdown) => {
65
+ Some(libsql_wal::checkpointer::CheckpointMessage::Shutdown) | None => {
66
break
67
}
68
Some(_) => (),
- None => break,
69
70
71
});
0 commit comments