summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/broadcast.rs5
-rw-r--r--src/db/mod.rs2
2 files changed, 6 insertions, 1 deletions
diff --git a/src/broadcast.rs b/src/broadcast.rs
index 2792a18..174016e 100644
--- a/src/broadcast.rs
+++ b/src/broadcast.rs
@@ -51,6 +51,11 @@ where
let rx = self.sender().subscribe();
BroadcastStream::from(rx).scan((), |(), r| {
+ // The following could technically be `r.ok()`, and is exactly
+ // equivalent to it, but spelling out the match arms means we'll
+ // find out at compile time if new errors get added to
+ // `BroadcastStreamRecvError`.
+ #[allow(clippy::manual_ok_err)]
future::ready(match r {
Ok(event) => Some(event),
// Stop the stream here. This will disconnect SSE clients
diff --git a/src/db/mod.rs b/src/db/mod.rs
index e0522d4..632cd9c 100644
--- a/src/db/mod.rs
+++ b/src/db/mod.rs
@@ -42,7 +42,7 @@ pub async fn prepare(url: &str, backup_url: &str) -> Result<SqlitePool, Error> {
Err(Error::Drop(drop_error, migrate_error))?;
} else {
Err(migrate_error)?;
- };
+ }
}
Sqlite::drop_database(backup_url).await?;